public class FieldExtractingAdapter extends Object implements IDatasourceAdapter
| Constructor and Description |
|---|
FieldExtractingAdapter(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
org.apache.hyracks.api.dataflow.value.RecordDescriptor inRecDesc,
org.apache.hyracks.api.dataflow.value.RecordDescriptor outRecDesc,
int[][] extractFields,
ARecordType rType,
IDatasourceAdapter wrappedAdapter) |
public FieldExtractingAdapter(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
org.apache.hyracks.api.dataflow.value.RecordDescriptor inRecDesc,
org.apache.hyracks.api.dataflow.value.RecordDescriptor outRecDesc,
int[][] extractFields,
ARecordType rType,
IDatasourceAdapter wrappedAdapter)
public void start(int partition,
org.apache.hyracks.api.comm.IFrameWriter writer)
throws Exception
start in interface IDatasourceAdapterExceptionCopyright © 2016 The Apache Software Foundation. All rights reserved.