Edge Data Streaming
- Edge Data Streaming 2.5.0
- All Products
package ...; import java.io.IOException; import com.informatica.vds.api.VDSConfiguration; import com.informatica.vds.api.VDSConsumptionSource; import com.informatica.vds.api.VDSEventList; public class SampleConsumptionSource implements VDSSource, VDSConsumptionSource { @Override public void open(VDSConfiguration ctx) throws Exception { // TODO Auto-generated method stub } @Override public void read(VDSEventList readEvents) throws Exception { // TODO Auto-generated method stub } @Override public void close() throws IOException { // TODO Auto-generated method stub } @Override public void onVDSEventConsume(Object obj) throws Exception { // TODO Auto-generated method stub } }