public FutureData<ODPBatchResponse> batch(String sourceId, String interactions) {
        FutureData<ODPBatchResponse> future = new FutureData<>();
        URI uri = newParams().forURL(config.newIngestionAPIEndpointURI(sourceId));
        JSONRequest request = config.http().postJSON(
                uri, new PageReader(newRequestCallback(future, new ODPBatchResponse(), config)))
                .setData(interactions);
        performRequest(future, request);
        return future;
    }
public FutureData < ODPBatchResponse > batch ( String sourceId , String interactions ) { FutureData < ODPBatchResponse > future = new FutureData < > ( ) ; URI uri = newParams ( ) . forURL ( config . newIngestionAPIEndpointURI ( sourceId ) ) ; JSONRequest request = config . http ( ) . postJSON ( uri , new PageReader ( newRequestCallback ( future , new ODPBatchResponse ( ) , config ) ) ) . setData ( interactions ) ; performRequest ( future , request ) ; return future ; }
/*
Send data to DataSift ODP ingestion endpoint using batch upload method.

@param sourceId the ODP source ID to use for data ingestion
@param interactions String containing new-line delimited data items
@return a result containing details on accepted interactions, or errors if batch failed