This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 05ea580 MINOR: Remove unused class (#5037)
05ea580 is described below
commit 05ea580091a230a7843e0a7312e7980fc54f302e
Author: Guozhang Wang <[email protected]>
AuthorDate: Fri May 18 10:58:10 2018 -0700
MINOR: Remove unused class (#5037)
Reviewers: Bill Bejeck <[email protected]>, Matthias J. Sax
<[email protected]>
---
.../internals/KTableKTableLeftJoinValueGetter.java | 58 ----------------------
1 file changed, 58 deletions(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinValueGetter.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinValueGetter.java
deleted file mode 100644
index 45349c5..0000000
---
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoinValueGetter.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/*
- * 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.kafka.streams.kstream.internals;
-
-import org.apache.kafka.streams.kstream.KeyValueMapper;
-import org.apache.kafka.streams.kstream.ValueJoiner;
-import org.apache.kafka.streams.processor.ProcessorContext;
-
-class KTableKTableLeftJoinValueGetter<K1, K2, V1, V2, R> implements
KTableValueGetter<K1, R> {
-
- private final KTableValueGetter<K1, V1> valueGetter1;
- private final KTableValueGetter<K2, V2> valueGetter2;
- private final ValueJoiner<V1, V2, R> joiner;
- private final KeyValueMapper<K1, V1, K2> keyMapper;
-
- KTableKTableLeftJoinValueGetter(final KTableValueGetter<K1, V1>
valueGetter1,
- final KTableValueGetter<K2, V2>
valueGetter2,
- final ValueJoiner<V1, V2, R> joiner,
- final KeyValueMapper<K1, V1, K2>
keyMapper) {
- this.valueGetter1 = valueGetter1;
- this.valueGetter2 = valueGetter2;
- this.joiner = joiner;
- this.keyMapper = keyMapper;
- }
-
- @Override
- public void init(ProcessorContext context) {
- valueGetter1.init(context);
- valueGetter2.init(context);
- }
-
- @Override
- public R get(K1 key) {
- V1 value1 = valueGetter1.get(key);
-
- if (value1 != null) {
- V2 value2 = valueGetter2.get(keyMapper.apply(key, value1));
- return joiner.apply(value1, value2);
- } else {
- return null;
- }
- }
-
-}
--
To stop receiving notification emails like this one, please contact
[email protected].
