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

Util.checkNotNull介绍

暂无

代码示例

代码示例来源：origin: io.zipkin.java/zipkin-transport-scribe

/**
 * {@link CollectorSampler#isSampled(Span) samples spans} to reduce load on the storage system.
 * Defaults to always sample.
 */
public Builder sampler(CollectorSampler sampler) {
 this.sampler = checkNotNull(sampler, "sampler");
 return this;
}

代码示例来源：origin: io.zipkin.java/transport-kafka

/** The zookeeper connect string, ex. 127.0.0.1:2181. No default */
public Builder zookeeper(String zookeeper) {
 this.zookeeper = checkNotNull(zookeeper, "zookeeper");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

/**
 * The index prefix to use when generating daily index names. Defaults to zipkin.
 */
public Builder index(String index) {
 this.index = checkNotNull(index, "index");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-storage-cassandra

/** Keyspace to store span and index data. Defaults to "zipkin" */
public Builder keyspace(String keyspace) {
 this.keyspace = checkNotNull(keyspace, "keyspace");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-storage-cassandra

/** Comma separated list of host addresses part of Cassandra cluster. You can also specify a custom port with 'host:port'. Defaults to localhost on port 9042 **/
public Builder contactPoints(String contactPoints) {
 this.contactPoints = checkNotNull(contactPoints, "contactPoints");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-transport-scribe

/** Category zipkin spans will be consumed from. Defaults to "zipkin" */
public Builder category(String category) {
 this.category = checkNotNull(category, "category");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-transport-kafka

/**
 * {@link CollectorSampler#isSampled(Span) samples spans} to reduce load on the storage system.
 * Defaults to always sample.
 */
public Builder sampler(CollectorSampler sampler) {
 this.sampler = checkNotNull(sampler, "sampler");
 return this;
}

代码示例来源：origin: io.zipkin.java/transport-kafka

/** The consumer group this process is consuming on behalf of. Defaults to "zipkin" */
public Builder groupId(String groupId) {
 this.groupId = checkNotNull(groupId, "groupId");
 return this;
}

代码示例来源：origin: io.zipkin.java/storage-jdbc

public Builder settings(Settings settings) {
 this.settings = checkNotNull(settings, "settings");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-transport-kafka

/** Topic zipkin spans will be consumed from. Defaults to "zipkin" */
public Builder topic(String topic) {
 this.topic = checkNotNull(topic, "topic");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-collector-kafka10

/** The bootstrapServers connect string, ex. 127.0.0.1:9092. No default. */
public Builder bootstrapServers(String bootstrapServers) {
 properties.put(BOOTSTRAP_SERVERS_CONFIG, checkNotNull(bootstrapServers, "bootstrapServers"));
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-storage-mysql

MySQLStorage(MySQLStorage.Builder builder) {
 this.datasource = checkNotNull(builder.datasource, "datasource");
 this.executor = checkNotNull(builder.executor, "executor");
 this.context = new DSLContexts(builder.settings, builder.listenerProvider);
 this.strictTraceId = builder.strictTraceId;
 this.schema = new Lazy<Schema>() {
  @Override protected Schema compute() {
   return new Schema(datasource, context, strictTraceId);
  }
 };
}

代码示例来源：origin: io.zipkin.java/spanstore-jdbc

public JDBCSpanStore(DataSource datasource, Settings settings, @Nullable ExecuteListenerProvider listenerProvider) {
 this.datasource = checkNotNull(datasource, "datasource");
 this.settings = checkNotNull(settings, "settings");
 this.listenerProvider = listenerProvider;
}

代码示例来源：origin: io.zipkin.java/zipkin-transport-kafka

@Override protected AsyncSpanConsumer compute() {
  AsyncSpanConsumer result = storage.asyncSpanConsumer(sampler, metrics);
  return checkNotNull(result, storage + ".asyncSpanConsumer()");
 }
});

代码示例来源：origin: io.zipkin.java/zipkin-transport-kafka

/** Aggregates and reports collection metrics to a monitoring system. Defaults to no-op. */
public Builder metrics(CollectorMetrics metrics) {
 this.metrics = checkNotNull(metrics, "metrics").forTransport("kafka");
 return this;
}

代码示例来源：origin: io.zipkin.java/transport-kafka

/** Aggregates and reports collection metrics to a monitoring system. Defaults to no-op. */
public Builder metrics(CollectorMetrics metrics) {
 this.metrics = checkNotNull(metrics, "metrics").forTransport("kafka");
 return this;
}

代码示例来源：origin: io.zipkin.java/zipkin-transport-scribe

/** Aggregates and reports collection metrics to a monitoring system. Defaults to no-op. */
public Builder metrics(CollectorMetrics metrics) {
 this.metrics = checkNotNull(metrics, "metrics").forTransport("scribe");
 return this;
}

代码示例来源：origin: io.zipkin.java/transport-kafka

@Override protected AsyncSpanConsumer compute() {
  AsyncSpanConsumer result = storage.asyncSpanConsumer(sampler, metrics);
  return checkNotNull(result, storage + ".asyncSpanConsumer()");
 }
});

代码示例来源：origin: io.zipkin.java/zipkin-storage-elasticsearch

/**
 * The client supplier to consume for connectivity to elasticsearch. Defaults to using the
 * transport-client based {@link NativeClient}, but can be overriden with a HTTP-speaking client
 * (e.g. for use in cloud environments where the transport protocol is not exposed).
 */
public static Builder builder(InternalElasticsearchClient.Builder clientBuilder) {
 return new Builder(checkNotNull(clientBuilder, "clientBuilder"));
}

代码示例来源：origin: io.zipkin.java/zipkin-collector-kafka10

@Override public Builder metrics(CollectorMetrics metrics) {
 this.metrics = checkNotNull(metrics, "metrics").forTransport("kafka");
 delegate.metrics(this.metrics);
 return this;
}