From e181d5288f2814f4065e6629c512ba7aafcc328b Mon Sep 17 00:00:00 2001 From: Kurtis Walker Date: Thu, 17 Oct 2019 14:02:12 -0400 Subject: [PATCH] [BACKLOG-31578] - pulling logic for determining sub-trans fields up to the parent streaming transformation --- .../plugins/kafka/KafkaConsumerInputDialog.java | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/kettle-plugins/kafka/src/main/java/org/pentaho/big/data/kettle/plugins/kafka/KafkaConsumerInputDialog.java b/kettle-plugins/kafka/src/main/java/org/pentaho/big/data/kettle/plugins/kafka/KafkaConsumerInputDialog.java index 860d2b43f3..56f76d75e2 100644 --- a/kettle-plugins/kafka/src/main/java/org/pentaho/big/data/kettle/plugins/kafka/KafkaConsumerInputDialog.java +++ b/kettle-plugins/kafka/src/main/java/org/pentaho/big/data/kettle/plugins/kafka/KafkaConsumerInputDialog.java @@ -43,7 +43,6 @@ import org.eclipse.swt.widgets.TableItem; import org.pentaho.di.core.Const; import org.pentaho.di.core.annotations.PluginDialog; -import org.pentaho.di.core.row.value.ValueMetaFactory; import org.pentaho.di.i18n.BaseMessages; import org.pentaho.di.trans.TransMeta; import org.pentaho.di.trans.step.StepDialogInterface; @@ -85,7 +84,6 @@ public class KafkaConsumerInputDialog extends BaseStreamingDialog implements Ste private TextVar wConsumerGroup; - private TableView fieldsTable; private TableView topicsTable; private TableView optionsTable; @@ -693,14 +691,5 @@ private void setTopicsFromTable() { private void setOptionsFromTable() { consumerMeta.setConfig( KafkaDialogHelper.getConfig( optionsTable ) ); } - - @Override protected String[] getFieldNames() { - return stream( fieldsTable.getTable().getItems() ).map( row -> row.getText( 2 ) ).toArray( String[]::new ); - } - - @Override protected int[] getFieldTypes() { - return stream( fieldsTable.getTable().getItems() ) - .mapToInt( row -> ValueMetaFactory.getIdForValueMeta( row.getText( 3 ) ) ).toArray(); - } }