public class PKGeneratingAdapter extends Object implements IDatasourceAdapter
| Constructor and Description |
|---|
PKGeneratingAdapter(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
org.apache.hyracks.api.dataflow.value.RecordDescriptor inRecDesc,
org.apache.hyracks.api.dataflow.value.RecordDescriptor outRecDesc,
ARecordType inRecType,
ARecordType outRecType,
IDatasourceAdapter wrappedAdapter,
int pkIndex) |
public PKGeneratingAdapter(org.apache.hyracks.api.context.IHyracksTaskContext ctx,
org.apache.hyracks.api.dataflow.value.RecordDescriptor inRecDesc,
org.apache.hyracks.api.dataflow.value.RecordDescriptor outRecDesc,
ARecordType inRecType,
ARecordType outRecType,
IDatasourceAdapter wrappedAdapter,
int pkIndex)
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.