diff options
author | Timothy Farkas <timothyfarkas@apache.org> | 2018-01-11 14:59:41 -0800 |
---|---|---|
committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2018-01-26 13:42:27 +0200 |
commit | 186536d544d02ffc01339a4645e2a533545a2f86 (patch) | |
tree | 24ddcb013b243ee501d5dfa1d73eb9c0a1511510 /exec/java-exec/src/main/java/org/apache/drill/exec/ops/ExecutorFragmentContext.java | |
parent | 9926eda21c748e96d67bce341a76dac3114002af (diff) |
DRILL-5730: Mock testing improvements and interface improvements
closes #1045
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/ops/ExecutorFragmentContext.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/ops/ExecutorFragmentContext.java | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/ExecutorFragmentContext.java b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/ExecutorFragmentContext.java new file mode 100644 index 000000000..82bb8865c --- /dev/null +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/ExecutorFragmentContext.java @@ -0,0 +1,56 @@ +/* + * 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 required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.drill.exec.ops; + +import org.apache.drill.exec.coord.ClusterCoordinator; +import org.apache.drill.exec.physical.impl.OperatorCreatorRegistry; +import org.apache.drill.exec.planner.PhysicalPlanReader; +import org.apache.drill.exec.proto.CoordinationProtos; +import org.apache.drill.exec.rpc.control.WorkEventBus; +import org.apache.drill.exec.rpc.user.UserServer; +import org.apache.drill.exec.server.QueryProfileStoreContext; +import org.apache.drill.exec.work.batch.IncomingBuffers; + +import java.util.Collection; +import java.util.Map; +import java.util.Set; + +public interface ExecutorFragmentContext extends RootFragmentContext { + + PhysicalPlanReader getPlanReader(); + + ClusterCoordinator getClusterCoordinator(); + + CoordinationProtos.DrillbitEndpoint getForemanEndpoint(); + + CoordinationProtos.DrillbitEndpoint getEndpoint(); + + Collection<CoordinationProtos.DrillbitEndpoint> getBits(); + + OperatorCreatorRegistry getOperatorCreatorRegistry(); + + void setBuffers(final IncomingBuffers buffers); + + QueryProfileStoreContext getProfileStoreContext(); + + WorkEventBus getWorkEventbus(); + + Set<Map.Entry<UserServer.BitToUserConnection, UserServer.BitToUserConnectionConfig>> getUserConnections(); + + boolean isUserAuthenticationEnabled(); +} |