This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-parallel-connector in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8e1af2e44ee5df9a894b815dba1b7abe7a2c06c5 Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Jun 12 23:40:35 2023 +0800 connector v2 --- .../pipe/connector/v2/IoTDBThriftConnectorV2.java | 46 ++++++++++++++++++++++ 1 file changed, 46 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/IoTDBThriftConnectorV2.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/IoTDBThriftConnectorV2.java new file mode 100644 index 00000000000..f6ec103bce0 --- /dev/null +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/v2/IoTDBThriftConnectorV2.java @@ -0,0 +1,46 @@ +/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless r [...] + +import org.apache.iotdb.common.rpc.thrift.TEndPoint; +import org.apache.iotdb.commons.client.ClientPoolFactory; +import org.apache.iotdb.commons.client.IClientManager; +import org.apache.iotdb.commons.client.async.AsyncPipeDataTransferServiceClient; +import org.apache.iotdb.pipe.api.PipeConnector; +import org.apache.iotdb.pipe.api.customizer.configuration.PipeConnectorRuntimeConfiguration; +import org.apache.iotdb.pipe.api.customizer.parameter.PipeParameterValidator; +import org.apache.iotdb.pipe.api.customizer.parameter.PipeParameters; +import org.apache.iotdb.pipe.api.event.Event; +import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent; +import org.apache.iotdb.pipe.api.event.dml.insertion.TsFileInsertionEvent; + +public class IoTDBThriftConnectorV2 implements PipeConnector { + private static final IClientManager<TEndPoint, AsyncPipeDataTransferServiceClient> + ASYNC_PIPE_DATA_TRANSFER_CLIENT_MANAGER = + new IClientManager.Factory<TEndPoint, AsyncPipeDataTransferServiceClient>() + .createClientManager( + new ClientPoolFactory.AsyncPipeDataTransferServiceClientPoolFactory()); + + @Override + public void validate(PipeParameterValidator validator) throws Exception {} + + @Override + public void customize(PipeParameters parameters, PipeConnectorRuntimeConfiguration configuration) + throws Exception {} + + @Override + public void handshake() throws Exception {} + + @Override + public void heartbeat() throws Exception {} + + @Override + public void transfer(TabletInsertionEvent tabletInsertionEvent) throws Exception {} + + @Override + public void transfer(TsFileInsertionEvent tsFileInsertionEvent) throws Exception {} + + @Override + public void transfer(Event event) throws Exception {} + + @Override + public void close() throws Exception {} +}
