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

WriteResponseMapper介绍

[英]An interface to implement a transformer from a system-native response type into a WriteResponse.
[中]将系统本机响应类型转换为WriterResponse的接口。

代码示例

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

@Override
public WriteResponse get()
  throws InterruptedException, ExecutionException {
 return _writeResponseMapper.wrap(_innerFuture.get());
}

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

@Override
 public WriteResponse get(long timeout, TimeUnit unit)
   throws InterruptedException, ExecutionException, TimeoutException {
  return _writeResponseMapper.wrap(_innerFuture.get(timeout, unit));
 }
}

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

/**
 * Write a single record to eventhub
 */
public WriteResponse write (String record) throws IOException {
 recordsAttempted.mark();
 String encoded = encodeRecord(record);
 int returnCode = request (encoded);
 recordsSuccess.mark();
 bytesWritten.mark(encoded.length());
 return WRITE_RESPONSE_WRAPPER.wrap(returnCode);
}

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

@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

@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: org.apache.gobblin/gobblin-core-base

@Override
public WriteResponse get()
  throws InterruptedException, ExecutionException {
 return _writeResponseMapper.wrap(_innerFuture.get());
}

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

@Override
 public WriteResponse get(long timeout, TimeUnit unit)
   throws InterruptedException, ExecutionException, TimeoutException {
  return _writeResponseMapper.wrap(_innerFuture.get(timeout, unit));
 }
}

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

/**
 * Write a single record to eventhub
 */
public WriteResponse write (String record) throws IOException {
 recordsAttempted.mark();
 String encoded = encodeRecord(record);
 int returnCode = request (encoded);
 recordsSuccess.mark();
 bytesWritten.mark(encoded.length());
 return WRITE_RESPONSE_WRAPPER.wrap(returnCode);
}

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

@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);
}