本文整理汇总了Java中org.apache.cassandra.metrics.StreamingMetrics类的典型用法代码示例。如果您正苦于以下问题:Java StreamingMetrics类的具体用法?Java StreamingMetrics怎么用?Java StreamingMetrics使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
StreamingMetrics类属于org.apache.cassandra.metrics包,在下文中一共展示了StreamingMetrics类的10个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: checkRegistrations
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
private boolean checkRegistrations(ObjectName name) {
if (name != null && server.isRegistered(name)) {
return false;
}
boolean result = false;
try {
String type = name != null ? name.getKeyProperty("type") : null;
if (type == null || tables.matcher(type).matches()) {
result |= ColumnFamilyStore.checkRegistration(client, server);
}
if (type == null || StreamingMetrics.TYPE_NAME.equals(type)) {
result |= StreamingMetrics.checkRegistration(client, server);
}
} catch (MalformedObjectNameException | UnknownHostException e) {
// TODO: log
}
return result;
}
开发者ID:scylladb,项目名称:scylla-jmx,代码行数:21,代码来源:APIMBeanServer.java
示例2: FileStreamTask
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
public FileStreamTask(StreamHeader header, InetAddress to)
{
this.header = header;
this.to = to;
this.throttle = new Throttle(toString(), new Throttle.ThroughputFunction()
{
/** @return Instantaneous throughput target in bytes per millisecond. */
public int targetThroughput()
{
if (DatabaseDescriptor.getStreamThroughputOutboundMegabitsPerSec() < 1)
// throttling disabled
return 0;
// total throughput
int totalBytesPerMS = DatabaseDescriptor.getStreamThroughputOutboundMegabitsPerSec() * 1024 * 1024 / 8 / 1000;
// per stream throughput (target bytes per MS)
return totalBytesPerMS / Math.max(1, (int)StreamingMetrics.activeStreamsOutbound.count());
}
});
metrics = StreamingMetrics.get(to);
}
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:21,代码来源:FileStreamTask.java
示例3: StreamSession
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Create new streaming session with the peer.
*
* @param peer Address of streaming peer
* @param connecting Actual connecting address
* @param factory is used for establishing connection
*/
public StreamSession(InetAddress peer, InetAddress connecting, StreamConnectionFactory factory, int index)
{
this.peer = peer;
this.connecting = connecting;
this.index = index;
this.factory = factory;
this.handler = new ConnectionHandler(this);
this.metrics = StreamingMetrics.get(connecting);
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:17,代码来源:StreamSession.java
示例4: fileSent
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Call back after sending FileMessageHeader.
*
* @param header sent header
*/
public void fileSent(FileMessageHeader header)
{
long headerSize = header.size();
StreamingMetrics.totalOutgoingBytes.inc(headerSize);
metrics.outgoingBytes.inc(headerSize);
// schedule timeout for receiving ACK
StreamTransferTask task = transfers.get(header.cfId);
if (task != null)
{
task.scheduleTimeout(header.sequenceNumber, 12, TimeUnit.HOURS);
}
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:18,代码来源:StreamSession.java
示例5: receive
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Call back after receiving FileMessageHeader.
*
* @param message received file
*/
public void receive(IncomingFileMessage message)
{
long headerSize = message.header.size();
StreamingMetrics.totalIncomingBytes.inc(headerSize);
metrics.incomingBytes.inc(headerSize);
// send back file received message
handler.sendMessage(new ReceivedMessage(message.header.cfId, message.header.sequenceNumber));
receivers.get(message.header.cfId).received(message.sstable);
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:15,代码来源:StreamSession.java
示例6: StreamSession
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Create new streaming session with the peer.
*
* @param peer Address of streaming peer
*/
public StreamSession(InetAddress peer)
{
this.peer = peer;
this.handler = new ConnectionHandler(this);
this.metrics = StreamingMetrics.get(peer);
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:12,代码来源:StreamSession.java
示例7: fileSent
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Call back after sending FileMessageHeader.
*
* @param header sent header
*/
public void fileSent(FileMessageHeader header)
{
long headerSize = header.size();
StreamingMetrics.totalOutgoingBytes.inc(headerSize);
metrics.outgoingBytes.inc(headerSize);
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:12,代码来源:StreamSession.java
示例8: receive
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Call back after receiving FileMessageHeader.
*
* @param message received file
*/
public void receive(FileMessage message)
{
long headerSize = message.header.size();
StreamingMetrics.totalIncomingBytes.inc(headerSize);
metrics.incomingBytes.inc(headerSize);
// send back file received message
handler.sendMessage(new ReceivedMessage(message.header.cfId, message.header.sequenceNumber));
receivers.get(message.header.cfId).received(message.sstable);
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:15,代码来源:StreamSession.java
示例9: StreamSession
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Create new streaming session with the peer.
*
* @param peer Address of streaming peer
* @param connecting Actual connecting address
* @param factory is used for establishing connection
*/
public StreamSession(InetAddress peer, InetAddress connecting, StreamConnectionFactory factory, int index, boolean keepSSTableLevel, boolean isIncremental)
{
this.peer = peer;
this.connecting = connecting;
this.index = index;
this.factory = factory;
this.handler = new ConnectionHandler(this);
this.metrics = StreamingMetrics.get(connecting);
this.keepSSTableLevel = keepSSTableLevel;
this.isIncremental = isIncremental;
}
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:19,代码来源:StreamSession.java
示例10: StreamSession
import org.apache.cassandra.metrics.StreamingMetrics; //导入依赖的package包/类
/**
* Create new streaming session with the peer.
*
* @param peer Address of streaming peer
* @param factory is used for establishing connection
*/
public StreamSession(InetAddress peer, StreamConnectionFactory factory, int index)
{
this.peer = peer;
this.index = index;
this.factory = factory;
this.handler = new ConnectionHandler(this);
this.metrics = StreamingMetrics.get(peer);
}
开发者ID:daidong,项目名称:GraphTrek,代码行数:15,代码来源:StreamSession.java
注:本文中的org.apache.cassandra.metrics.StreamingMetrics类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论