Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
Merge pull request #1819 from kurtwalker/backlog-31578
[BACKLOG-31578] - pulling logic for determining sub-trans fields up to
  • Loading branch information
mkambol committed Oct 17, 2019
2 parents c622105 + e181d52 commit 340218d
Showing 1 changed file with 0 additions and 11 deletions.
Expand Up @@ -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;
Expand Down Expand Up @@ -85,7 +84,6 @@ public class KafkaConsumerInputDialog extends BaseStreamingDialog implements Ste


private TextVar wConsumerGroup;
private TableView fieldsTable;
private TableView topicsTable;
private TableView optionsTable;

Expand Down Expand Up @@ -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();
}
}

0 comments on commit 340218d

Please sign in to comment.