本文整理了Java中org.apache.gobblin.writer.WriteResponseFuture.<init>()方法的一些代码示例，展示了WriteResponseFuture.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WriteResponseFuture.<init>()方法的具体详情如下：
包路径：org.apache.gobblin.writer.WriteResponseFuture
类名称：WriteResponseFuture
方法名：<init>

WriteResponseFuture.<init>介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-gobblin

@Override
public Future<WriteResponse> write(final D record, final WriteCallback callback) {
 return new WriteResponseFuture<>(this.producer.send(new ProducerRecord<String, D>(topic, record), new Callback() {
  @Override
  public void onCompletion(final RecordMetadata metadata, Exception exception) {
   if (exception != null) {
    callback.onFailure(exception);
   } else {
    callback.onSuccess(WRITE_RESPONSE_WRAPPER.wrap(metadata));
   }
  }
 }), WRITE_RESPONSE_WRAPPER);
}

代码示例来源：origin: apache/incubator-gobblin

/**
 * Asynchronously write a record, execute the callback on success/failure
 */
public Future<WriteResponse> write(D record, @Nullable WriteCallback callback) {
 try {
  Future<RecordMetadata> future = this.accumulator.append(record, callback);
  return new WriteResponseFuture (future, WRITE_RESPONSE_WRAPPER);
 } catch (InterruptedException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: apache/incubator-gobblin

@Override
public Future<WriteResponse> write(final D record, final WriteCallback callback) {
 return new WriteResponseFuture<>(this.producer.send(new ProducerRecord<String, D>(topic, record), new Callback() {
  @Override
  public void onCompletion(final RecordMetadata metadata, Exception exception) {
   if (exception != null) {
    callback.onFailure(exception);
   } else {
    callback.onSuccess(WRITE_RESPONSE_WRAPPER.wrap(metadata));
   }
  }
 }), WRITE_RESPONSE_WRAPPER);
}

代码示例来源：origin: apache/incubator-gobblin

/**
 * Write a whole batch to eventhub
 */
public Future<WriteResponse> write (Batch<String> batch, WriteCallback callback) {
 Timer.Context context = writeTimer.time();
 int returnCode = 0;
 LOG.info ("Dispatching batch " + batch.getId());
 recordsAttempted.mark(batch.getRecords().size());
 try {
  String encoded = encodeBatch(batch);
  returnCode = request (encoded);
  WriteResponse<Integer> response = WRITE_RESPONSE_WRAPPER.wrap(returnCode);
  callback.onSuccess(response);
  bytesWritten.mark(encoded.length());
  recordsSuccess.mark(batch.getRecords().size());
 } catch (Exception e) {
  LOG.error("Dispatching batch " + batch.getId() + " failed :" + e.toString());
  callback.onFailure(e);
  recordsFailed.mark(batch.getRecords().size());
 }
 context.close();
 Future<Integer> future = Futures.immediateFuture(returnCode);
 return new WriteResponseFuture<>(future, WRITE_RESPONSE_WRAPPER);
}

代码示例来源：origin: apache/incubator-gobblin

return new WriteResponseFuture<>(
  observable.timeout(_operationTimeout, _operationTimeunit).toBlocking().toFuture(),
  _defaultWriteResponseMapper);

代码示例来源：origin: org.apache.gobblin/gobblin-core-base

/**
 * Asynchronously write a record, execute the callback on success/failure
 */
public Future<WriteResponse> write(D record, @Nullable WriteCallback callback) {
 try {
  Future<RecordMetadata> future = this.accumulator.append(record, callback);
  return new WriteResponseFuture (future, WRITE_RESPONSE_WRAPPER);
 } catch (InterruptedException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: org.apache.gobblin/gobblin-kafka-08

@Override
public Future<WriteResponse> write(final D record, final WriteCallback callback) {
 return new WriteResponseFuture<>(this.producer.send(new ProducerRecord<String, D>(topic, record), new Callback() {
  @Override
  public void onCompletion(final RecordMetadata metadata, Exception exception) {
   if (exception != null) {
    callback.onFailure(exception);
   } else {
    callback.onSuccess(WRITE_RESPONSE_WRAPPER.wrap(metadata));
   }
  }
 }), WRITE_RESPONSE_WRAPPER);
}

代码示例来源：origin: org.apache.gobblin/gobblin-eventhub

/**
 * Write a whole batch to eventhub
 */
public Future<WriteResponse> write (Batch<String> batch, WriteCallback callback) {
 Timer.Context context = writeTimer.time();
 int returnCode = 0;
 LOG.info ("Dispatching batch " + batch.getId());
 recordsAttempted.mark(batch.getRecords().size());
 try {
  String encoded = encodeBatch(batch);
  returnCode = request (encoded);
  WriteResponse<Integer> response = WRITE_RESPONSE_WRAPPER.wrap(returnCode);
  callback.onSuccess(response);
  bytesWritten.mark(encoded.length());
  recordsSuccess.mark(batch.getRecords().size());
 } catch (Exception e) {
  LOG.error("Dispatching batch " + batch.getId() + " failed :" + e.toString());
  callback.onFailure(e);
  recordsFailed.mark(batch.getRecords().size());
 }
 context.close();
 Future<Integer> future = Futures.immediateFuture(returnCode);
 return new WriteResponseFuture<>(future, WRITE_RESPONSE_WRAPPER);
}