From f5f422219453bb6545eaf7f8d39843909bcc1d6b Mon Sep 17 00:00:00 2001 From: wusheng Date: Wed, 30 Nov 2016 18:13:00 +0800 Subject: [PATCH] Add a IndexOperatorTest. --- .../storage/data/index/IndexOperatorTest.java | 47 +++++++++++++++++++ 1 file changed, 47 insertions(+) create mode 100644 skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/index/IndexOperatorTest.java diff --git a/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/index/IndexOperatorTest.java b/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/index/IndexOperatorTest.java new file mode 100644 index 0000000000..1f7d6613e2 --- /dev/null +++ b/skywalking-storage-center/skywalking-storage/src/test/java/com/a/eye/skywalking/storage/data/index/IndexOperatorTest.java @@ -0,0 +1,47 @@ +package com.a.eye.skywalking.storage.data.index; + +import com.a.eye.skywalking.network.grpc.RequestSpan; +import com.a.eye.skywalking.network.grpc.TraceId; +import com.a.eye.skywalking.storage.data.file.DataFileNameDesc; +import com.a.eye.skywalking.storage.data.spandata.RequestSpanData; +import com.a.eye.skywalking.storage.util.NetUtils; +import org.elasticsearch.client.transport.TransportClient; +import org.elasticsearch.common.settings.Settings; +import org.elasticsearch.common.transport.InetSocketTransportAddress; +import org.elasticsearch.transport.client.PreBuiltTransportClient; + +import java.net.InetAddress; +import java.net.UnknownHostException; + +/** + * Created by wusheng on 2016/11/30. + */ +public class IndexOperatorTest { + public static void main(String[] args) { + try { + TransportClient client = new PreBuiltTransportClient(Settings.EMPTY).addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("test_es"), 9300)); + IndexOperator operator = new IndexOperator(client); + + for (int i = 0; i < 1_000_000_000; i++) { + IndexMetaCollection collection = new IndexMetaCollection(); + for (int j = 0; j < 100; j++) { + RequestSpan requestSpan = + RequestSpan.newBuilder().setSpanType(1).setAddress(NetUtils.getLocalAddress().toString()).setApplicationId("1").setCallType("1").setLevelId(0) + .setProcessNo(19287).setStartDate(System.currentTimeMillis()).setTraceId( + TraceId.newBuilder().addSegments(201611).addSegments(j).addSegments(8504828).addSegments(2277).addSegments(53).addSegments(3).build()) + .setUserId("1").setViewPointId("http://localhost:8080/wwww/test/helloWorld").setRouteKey(i).build(); + IndexMetaInfo info = new IndexMetaInfo(new RequestSpanData(requestSpan), new DataFileNameDesc(), i, j); + collection.add(info); + } + + operator.batchUpdate(collection); + + if (i % 100 == 0) { + System.out.println(" num=" + i + " "); + } + } + } catch (UnknownHostException e) { + e.printStackTrace(); + } + } +} -- GitLab