Skip to content

Commit

Permalink
Removes need for transformation name argument apache#4006
Browse files Browse the repository at this point in the history
  • Loading branch information
nadment authored and hansva committed Jun 7, 2024
1 parent 8298860 commit e9459c3
Show file tree
Hide file tree
Showing 223 changed files with 463 additions and 928 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,9 +64,8 @@ public AccessOutputDialog(
Shell parent,
IVariables variables,
AccessOutputMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,8 @@ public BeamBigtableInputDialog(
Shell parent,
IVariables variables,
BeamBigtableInputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,9 +57,8 @@ public BeamBigtableOutputDialog(
Shell parent,
IVariables variables,
BeamBigtableOutputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,9 +72,8 @@ public BeamBQInputDialog(
Shell parent,
IVariables variables,
BeamBQInputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,8 @@ public BeamBQOutputDialog(
Shell parent,
IVariables variables,
BeamBQOutputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,9 +53,8 @@ public BeamHiveCatalogInputDialog(
Shell parent,
IVariables variables,
BeamHiveCatalogInputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,12 +51,8 @@ public class BeamInputDialog extends BaseTransformDialog {
private MetaSelectionLine<FileDefinition> wFileDefinition;

public BeamInputDialog(
Shell parent,
IVariables variables,
BeamInputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
Shell parent, IVariables variables, BeamInputMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,12 +54,8 @@ public class BeamOutputDialog extends BaseTransformDialog {
private Button wWindowed;

public BeamOutputDialog(
Shell parent,
IVariables variables,
BeamOutputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
Shell parent, IVariables variables, BeamOutputMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,9 +67,8 @@ public BeamConsumeDialog(
Shell parent,
IVariables variables,
BeamConsumeMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,9 +57,8 @@ public BeamProduceDialog(
Shell parent,
IVariables variables,
BeamProduceMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,9 +75,8 @@ public BeamKinesisConsumeDialog(
Shell parent,
IVariables variables,
BeamKinesisConsumeMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,8 @@ public BeamKinesisProduceDialog(
Shell parent,
IVariables variables,
BeamKinesisProduceMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,9 +53,8 @@ public BeamPublishDialog(
Shell parent,
IVariables variables,
BeamPublishMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,9 +54,8 @@ public BeamSubscribeDialog(
Shell parent,
IVariables variables,
BeamSubscribeMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,9 +51,8 @@ public BeamTimestampDialog(
Shell parent,
IVariables variables,
BeamTimestampMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,12 +56,8 @@ public class BeamWindowDialog extends BaseTransformDialog {
private Combo wTriggerType;

public BeamWindowDialog(
Shell parent,
IVariables variables,
BeamWindowMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
Shell parent, IVariables variables, BeamWindowMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,8 @@ public PipelineLoggingDialog(
Shell parent,
IVariables variables,
PipelineLoggingMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
this.input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,9 +46,8 @@ public PipelineDataProbeDialog(
Shell parent,
IVariables variables,
PipelineDataProbeMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
this.input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,8 @@ public WorkflowLoggingDialog(
Shell parent,
IVariables variables,
WorkflowLoggingMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
this.input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,10 +62,8 @@ public ExecuteTestsDialog(
Shell parent,
IVariables variables,
ExecuteTestsMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);

PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -74,12 +74,8 @@ public class AvroDecodeDialog extends BaseTransformDialog {
private RowProducer rowProducer;

public AvroDecodeDialog(
Shell parent,
IVariables variables,
AvroDecodeMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
Shell parent, IVariables variables, AvroDecodeMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);

input = transformMeta;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,12 +54,8 @@ public class AvroEncodeDialog extends BaseTransformDialog {
private TableView wFields;

public AvroEncodeDialog(
Shell parent,
IVariables variables,
AvroEncodeMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
Shell parent, IVariables variables, AvroEncodeMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);

input = transformMeta;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,9 +52,8 @@ public AvroFileInputDialog(
Shell parent,
IVariables variables,
AvroFileInputMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);

input = transformMeta;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -114,12 +114,8 @@ public class AvroOutputDialog extends BaseTransformDialog {
private String[] avroFieldNames = null;

public AvroOutputDialog(
Shell parent,
IVariables variables,
AvroOutputMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
Shell parent, IVariables variables, AvroOutputMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,12 +113,8 @@ public class SnsNotifyDialog extends BaseTransformDialog {
* @param transformName the transform name
*/
public SnsNotifyDialog(
Shell parent,
IVariables variables,
SnsNotifyMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
Shell parent, IVariables variables, SnsNotifyMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
meta = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -112,15 +112,10 @@ public class SqsReaderDialog extends BaseTransformDialog {
* @param parent the SWT shell to open the dialog in
* @param in the meta object holding the transform's settings
* @param pipelineMeta pipeline description
* @param sname the transform name
*/
public SqsReaderDialog(
Shell parent,
IVariables variables,
SqsReaderMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
Shell parent, IVariables variables, SqsReaderMeta transformMeta, PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
meta = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -137,9 +137,8 @@ public RedshiftBulkLoaderDialog(
Shell parent,
IVariables variables,
RedshiftBulkLoaderMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
inputFields = new HashMap<>();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,9 +76,8 @@ public AzureListenerDialog(
Shell parent,
IVariables variables,
AzureListenerMeta transformMeta,
PipelineMeta pipelineMeta,
String transformName) {
super(parent, variables, transformMeta, pipelineMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,8 @@ public AzureWriterDialog(
Shell parent,
IVariables variables,
AzureWriterMeta inputMetadata,
PipelineMeta transMeta,
String transformName) {
super(parent, variables, inputMetadata, transMeta, transformName);
PipelineMeta pipelineMeta) {
super(parent, variables, inputMetadata, pipelineMeta);
input = inputMetadata;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,9 +76,8 @@ public CassandraInputDialog(
Shell parent,
IVariables variables,
CassandraInputMeta transformMeta,
PipelineMeta pipelineMeta,
String name) {
super(parent, variables, transformMeta, pipelineMeta, name);
PipelineMeta pipelineMeta) {
super(parent, variables, transformMeta, pipelineMeta);
input = transformMeta;
}

Expand Down
Loading

0 comments on commit e9459c3

Please sign in to comment.