You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by dp...@apache.org on 2017/10/17 18:08:29 UTC
[10/20] lucene-solr:branch_7x: SOLR-11145,
SOLR-11146: Added comprehensive unit tests for Analytics Component
2.0 as well as analytics bug fixes.
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a6d1681a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DateParseFunctionTest.java
----------------------------------------------------------------------
diff --git a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DateParseFunctionTest.java b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DateParseFunctionTest.java
new file mode 100644
index 0000000..2f34833
--- /dev/null
+++ b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DateParseFunctionTest.java
@@ -0,0 +1,245 @@
+/*
+ * 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.solr.analytics.function.mapping;
+
+import java.time.Instant;
+import java.time.format.DateTimeParseException;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.Iterator;
+
+import org.apache.solr.SolrTestCaseJ4;
+import org.apache.solr.analytics.value.AnalyticsValueStream;
+import org.apache.solr.analytics.value.DateValue;
+import org.apache.solr.analytics.value.DateValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestLongValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestLongValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestStringValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestStringValueStream;
+import org.junit.Test;
+
+public class DateParseFunctionTest extends SolrTestCaseJ4 {
+
+ @Test
+ public void singleValueLongTest() throws DateTimeParseException {
+ Date date1 = Date.from(Instant.parse("1800-01-01T10:30:15Z"));
+ Date date2 = Date.from(Instant.parse("1920-04-15T18:15:45Z"));
+ TestLongValue val = new TestLongValue();
+
+ AnalyticsValueStream uncasted = DateParseFunction.creatorFunction.apply(new AnalyticsValueStream[] {val});
+ assertTrue(uncasted instanceof DateValue);
+ DateValue func = (DateValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ func.getDate();
+ assertFalse(func.exists());
+ func.getLong();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue(date1.getTime()).setExists(true);
+ assertEquals(date1, func.getDate());
+ assertTrue(func.exists());
+ assertEquals(date1.getTime(), func.getLong());
+ assertTrue(func.exists());
+
+ val.setValue(date2.getTime()).setExists(true);
+ assertEquals(date2, func.getDate());
+ assertTrue(func.exists());
+ assertEquals(date2.getTime(), func.getLong());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueStringTest() throws DateTimeParseException {
+ Date date1 = Date.from(Instant.parse("1800-01-01T10:30:15Z"));
+ Date date2 = Date.from(Instant.parse("1920-04-15T18:15:45Z"));
+ TestStringValue val = new TestStringValue();
+
+ AnalyticsValueStream uncasted = DateParseFunction.creatorFunction.apply(new AnalyticsValueStream[] {val});
+ assertTrue(uncasted instanceof DateValue);
+ DateValue func = (DateValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ func.getDate();
+ assertFalse(func.exists());
+ func.getLong();
+ assertFalse(func.exists());
+
+ // Incorrect Value
+ val.setValue("1800-01T10:30:15Z").setExists(true);
+ func.getDate();
+ assertFalse(func.exists());
+ func.getLong();
+ assertFalse(func.exists());
+
+ val.setValue("1800-01-T::Z").setExists(true);
+ func.getDate();
+ assertFalse(func.exists());
+ func.getLong();
+ assertFalse(func.exists());
+
+ val.setValue("1800--01T30:30:15Z").setExists(true);
+ func.getDate();
+ assertFalse(func.exists());
+ func.getLong();
+ assertFalse(func.exists());
+
+
+ // Value exists
+ val.setValue("1800-01-01T10:30:15Z").setExists(true);
+ assertEquals(date1, func.getDate());
+ assertTrue(func.exists());
+ assertEquals(date1.getTime(), func.getLong());
+ assertTrue(func.exists());
+
+ val.setValue("1920-04-15T18:15:45Z").setExists(true);
+ assertEquals(date2, func.getDate());
+ assertTrue(func.exists());
+ assertEquals(date2.getTime(), func.getLong());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void multiValueLongTest() throws DateTimeParseException {
+ Date date1 = Date.from(Instant.parse("1800-01-01T10:30:15Z"));
+ Date date2 = Date.from(Instant.parse("1920-04-15T18:15:45Z"));
+ Date date3 = Date.from(Instant.parse("2012-11-30T20:30:15Z"));
+ TestLongValueStream val = new TestLongValueStream();
+
+ AnalyticsValueStream uncasted = DateParseFunction.creatorFunction.apply(new AnalyticsValueStream[] {val});
+ assertTrue(uncasted instanceof DateValueStream);
+ DateValueStream func = (DateValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ func.streamDates( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val.setValues(date1.getTime());
+ Iterator<Date> values1 = Arrays.asList(date1).iterator();
+ func.streamDates( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+ Iterator<Long> times1 = Arrays.asList(date1.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(times1.hasNext());
+ assertEquals(times1.next().longValue(), value);
+ });
+ assertFalse(times1.hasNext());
+
+ // Multiple values
+ val.setValues(date1.getTime(), date2.getTime(), date3.getTime());
+ Iterator<Date> values2 = Arrays.asList(date1, date2, date3).iterator();
+ func.streamDates( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ Iterator<Long> times2 = Arrays.asList(date1.getTime(), date2.getTime(), date3.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(times2.hasNext());
+ assertEquals(times2.next().longValue(), value);
+ });
+ assertFalse(times2.hasNext());
+ }
+
+ @Test
+ public void multiValueStringTest() throws DateTimeParseException {
+ Date date1 = Date.from(Instant.parse("1800-01-01T10:30:15Z"));
+ Date date2 = Date.from(Instant.parse("1920-04-15T18:15:45Z"));
+ Date date3 = Date.from(Instant.parse("2012-11-30T20:30:15Z"));
+ TestStringValueStream val = new TestStringValueStream();
+
+ AnalyticsValueStream uncasted = DateParseFunction.creatorFunction.apply(new AnalyticsValueStream[] {val});
+ assertTrue(uncasted instanceof DateValueStream);
+ DateValueStream func = (DateValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ func.streamDates( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Incorrect value
+ val.setValues("10:30:15Z");
+ func.streamDates( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val.setValues("01-33T10:30:15Z");
+ func.streamDates( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val.setValues("1800-01T30:30:15Z");
+ func.streamDates( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val.setValues("1800-01-01T10:30:15Z");
+ Iterator<Date> values1 = Arrays.asList(date1).iterator();
+ func.streamDates( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+ Iterator<Long> times1 = Arrays.asList(date1.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(times1.hasNext());
+ assertEquals(times1.next().longValue(), value);
+ });
+ assertFalse(times1.hasNext());
+
+ // Multiple values
+ val.setValues("1800-01-01T10:30:15Z", "1920-04-15T18:15:45Z", "2012-11-30T20:30:15Z");
+ Iterator<Date> values2 = Arrays.asList(date1, date2, date3).iterator();
+ func.streamDates( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ Iterator<Long> times2 = Arrays.asList(date1.getTime(), date2.getTime(), date3.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(times2.hasNext());
+ assertEquals(times2.next().longValue(), value);
+ });
+ assertFalse(times2.hasNext());
+ }
+}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a6d1681a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DivideFunctionTest.java
----------------------------------------------------------------------
diff --git a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DivideFunctionTest.java b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DivideFunctionTest.java
new file mode 100644
index 0000000..5ca324d
--- /dev/null
+++ b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/DivideFunctionTest.java
@@ -0,0 +1,128 @@
+/*
+ * 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.solr.analytics.function.mapping;
+
+import java.util.Arrays;
+import java.util.Iterator;
+
+import org.apache.solr.SolrTestCaseJ4;
+import org.apache.solr.analytics.value.AnalyticsValueStream;
+import org.apache.solr.analytics.value.DoubleValue;
+import org.apache.solr.analytics.value.DoubleValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestDoubleValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestFloatValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestIntValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestLongValueStream;
+import org.junit.Test;
+
+public class DivideFunctionTest extends SolrTestCaseJ4 {
+ @Test
+ public void twoSingleValueParametersTest() {
+ TestIntValue dividend = new TestIntValue();
+ TestFloatValue divisor = new TestFloatValue();
+
+ AnalyticsValueStream uncasted = DivideFunction.creatorFunction.apply(new AnalyticsValueStream[] {dividend, divisor});
+ assertTrue(uncasted instanceof DoubleValue);
+ DoubleValue func = (DoubleValue) uncasted;
+
+ // Neither exists
+ dividend.setExists(false);
+ divisor.setExists(false);
+ func.getDouble();
+ assertFalse(func.exists());
+
+ // One exists
+ dividend.setValue(30).setExists(true);
+ divisor.setExists(false);
+ func.getDouble();
+ assertFalse(func.exists());
+
+ // Both exist
+ dividend.setValue(60).setExists(true);
+ divisor.setValue(23.56F).setExists(true);
+ assertEquals(2.546689, func.getDouble(), 0.00001);
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void oneMultiOneSingleValueParameterTest() {
+ TestLongValueStream dividend = new TestLongValueStream();
+ TestDoubleValue divisor = new TestDoubleValue();
+
+ AnalyticsValueStream uncasted = DivideFunction.creatorFunction.apply(new AnalyticsValueStream[] {dividend, divisor});
+ assertTrue(uncasted instanceof DoubleValueStream);
+ DoubleValueStream func = (DoubleValueStream) uncasted;
+
+ // No values, One value
+ dividend.setValues();
+ divisor.setValue(21.56F).setExists(true);
+ func.streamDoubles( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Multiple values, no value
+ dividend.setValues(4L, 10023L);
+ divisor.setExists(false);
+ func.streamDoubles( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Multiple values, one value
+ dividend.setValues(20L, 5L, -234L);
+ divisor.setValue(44.56F).setExists(true);
+ Iterator<Double> values = Arrays.asList(0.448833, 0.112208, -5.251346).iterator();
+ func.streamDoubles( value -> {
+ assertTrue(values.hasNext());
+ assertEquals(values.next(), value, 0.00001);
+ });
+ assertFalse(values.hasNext());
+ }
+
+ @Test
+ public void oneSingleOneMultiValueParameterTest() {
+ TestDoubleValue dividend = new TestDoubleValue();
+ TestLongValueStream divisor = new TestLongValueStream();
+
+ AnalyticsValueStream uncasted = DivideFunction.creatorFunction.apply(new AnalyticsValueStream[] {dividend, divisor});
+ assertTrue(uncasted instanceof DoubleValueStream);
+ DoubleValueStream func = (DoubleValueStream) uncasted;
+
+ // No values, One value
+ dividend.setValue(21.56F).setExists(true);
+ divisor.setValues();
+ func.streamDoubles( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Multiple values, no value
+ dividend.setExists(false);
+ divisor.setValues(4L, 10023L);
+ func.streamDoubles( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Multiple values, one value
+ dividend.setValue(44.56F).setExists(true);
+ divisor.setValues(20L, 5L, -234L);
+ Iterator<Double> values = Arrays.asList(2.228, 8.912, -0.190427).iterator();
+ func.streamDoubles( value -> {
+ assertTrue(values.hasNext());
+ assertEquals(values.next(), value, 0.00001);
+ });
+ assertFalse(values.hasNext());
+ }
+}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a6d1681a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/EqualFunctionTest.java
----------------------------------------------------------------------
diff --git a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/EqualFunctionTest.java b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/EqualFunctionTest.java
new file mode 100644
index 0000000..6495f96
--- /dev/null
+++ b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/EqualFunctionTest.java
@@ -0,0 +1,530 @@
+/*
+ * 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.solr.analytics.function.mapping;
+
+import java.util.Arrays;
+import java.util.Iterator;
+
+import org.apache.solr.SolrTestCaseJ4;
+import org.apache.solr.analytics.function.mapping.EqualFunction;
+import org.apache.solr.analytics.value.AnalyticsValueStream;
+import org.apache.solr.analytics.value.BooleanValue;
+import org.apache.solr.analytics.value.BooleanValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestBooleanValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestBooleanValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestDateValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestDateValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestDoubleValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestDoubleValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestStringValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestStringValueStream;
+import org.junit.Test;
+
+public class EqualFunctionTest extends SolrTestCaseJ4 {
+
+ @Test
+ public void singleValueBooleanParameterTest() {
+ TestBooleanValue val1 = new TestBooleanValue();
+ TestBooleanValue val2 = new TestBooleanValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ // Value doesn't exist
+ val1.setExists(false);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setExists(false);
+ val2.setValue(false).setExists(true);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setValue(true).setExists(true);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ // Value exists
+ val1.setValue(false).setExists(true);
+ val2.setValue(false).setExists(true);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+
+ val1.setValue(false).setExists(true);
+ val2.setValue(true).setExists(true);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueNumericParameterTest() {
+ TestDoubleValue val1 = new TestDoubleValue();
+ TestDoubleValue val2 = new TestDoubleValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ // Value doesn't exist
+ val1.setExists(false);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setExists(false);
+ val2.setValue(3.3).setExists(true);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setValue(3.3).setExists(true);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ // Value exists
+ val1.setValue(21.56).setExists(true);
+ val2.setValue(21.56).setExists(true);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+
+ val1.setValue(21.56).setExists(true);
+ val2.setValue(21.57).setExists(true);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueDateParameterTest() {
+ TestDateValue val1 = new TestDateValue();
+ TestDateValue val2 = new TestDateValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ // Value doesn't exist
+ val1.setExists(false);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setExists(false);
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setValue("1800-01-02T10:20:30Z").setExists(true);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ // Value exists
+ val1.setValue("1800-01-02T10:20:30Z").setExists(true);
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+
+ val1.setValue("1800-01-02T10:20:30Z").setExists(true);
+ val2.setValue("1800-01-02T10:20:31Z").setExists(true);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueStringParameterTest() {
+ TestStringValue val1 = new TestStringValue();
+ TestStringValue val2 = new TestStringValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ // Value doesn't exist
+ val1.setExists(false);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setExists(false);
+ val2.setValue("abcdefghi").setExists(true);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ val1.setValue("abcdefghi").setExists(true);
+ val2.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ // Value exists
+ val1.setValue("abcdefghi").setExists(true);
+ val2.setValue("abcdefghi").setExists(true);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+
+ val1.setValue("abcdefghi1").setExists(true);
+ val2.setValue("abcdefghi2").setExists(true);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void oneSingleOneMultiValueBooleanParameterTest() {
+ TestBooleanValueStream val1 = new TestBooleanValueStream();
+ TestBooleanValue val2 = new TestBooleanValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue(false).setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues(true);
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues(false);
+ val2.setValue(false).setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues(false, true, true, false, false);
+ val2.setValue(false).setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, false, true, true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneMultiOneSingleValueBooleanParameterTest() {
+ TestBooleanValueStream val1 = new TestBooleanValueStream();
+ TestBooleanValue val2 = new TestBooleanValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val2, val1});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue(false).setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues(true);
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues(false);
+ val2.setValue(false).setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues(false, true, true, false, false);
+ val2.setValue(false).setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, false, true, true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneSingleOneMultiValueNumericParameterTest() {
+ TestDoubleValueStream val1 = new TestDoubleValueStream();
+ TestDoubleValue val2 = new TestDoubleValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue(-4.2).setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues(-4.2);
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues(-4.2);
+ val2.setValue(-4.2).setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues(4, -10, 4, -74, 4.0001);
+ val2.setValue(4).setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, true, false, false).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneMultiOneSingleValueNumericParameterTest() {
+ TestDoubleValueStream val1 = new TestDoubleValueStream();
+ TestDoubleValue val2 = new TestDoubleValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val2, val1});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue(-4.2).setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues(-4.2);
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues(-4.2);
+ val2.setValue(-4.2).setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues(4, -10, 4, -74, 4.0001);
+ val2.setValue(4).setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, true, false, false).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneSingleOneMultiValueDateParameterTest() {
+ TestDateValueStream val1 = new TestDateValueStream();
+ TestDateValue val2 = new TestDateValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues("1800-01-02T10:20:30Z");
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues("1800-01-02T10:20:30Z");
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues("1800-01-02T10:20:30Z", "1800-01-02T10:20:31Z", "1800-01-02T10:20:30Z", "1801-01-02T10:20:30Z");
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, true, false).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneMultiOneSingleValueDateParameterTest() {
+ TestDateValueStream val1 = new TestDateValueStream();
+ TestDateValue val2 = new TestDateValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val2, val1});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues("1800-01-02T10:20:30Z");
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues("1800-01-02T10:20:30Z");
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues("1800-01-02T10:20:30Z", "1800-01-02T10:20:31Z", "1800-01-02T10:20:30Z", "9999-01-02T10:20:30Z");
+ val2.setValue("1800-01-02T10:20:30Z").setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, true, false).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneSingleOneMultiValueStringParameterTest() {
+ TestStringValueStream val1 = new TestStringValueStream();
+ TestStringValue val2 = new TestStringValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val1, val2});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue("abcdefghi").setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues("abcdefghi");
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues("abcdefghi");
+ val2.setValue("abcdefghi").setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues("abcdefghi", "abcdefghi1", "sbcdefghi", "abcdefghi");
+ val2.setValue("abcdefghi").setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, false, true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+
+ @Test
+ public void oneMultiOneSingleValueStringParameterTest() {
+ TestStringValueStream val1 = new TestStringValueStream();
+ TestStringValue val2 = new TestStringValue();
+
+ AnalyticsValueStream uncasted = EqualFunction.creatorFunction.apply(new AnalyticsValueStream[] {val2, val1});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val1.setValues();
+ val2.setValue("abcdefghi").setExists(true);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ val1.setValues("abcdefghi");
+ val2.setExists(false);
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // One value
+ val1.setValues("abcdefghi");
+ val2.setValue("abcdefghi").setExists(true);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ // Multiple values
+ val1.setValues("abcdefghi", "abcdefghi1", "sbcdefghi", "abcdefghi");
+ val2.setValue("abcdefghi").setExists(true);
+ Iterator<Boolean> values2 = Arrays.asList(true, false, false, true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+ }
+}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a6d1681a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/ExistsFunctionTest.java
----------------------------------------------------------------------
diff --git a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/ExistsFunctionTest.java b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/ExistsFunctionTest.java
new file mode 100644
index 0000000..89fcf42
--- /dev/null
+++ b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/ExistsFunctionTest.java
@@ -0,0 +1,74 @@
+/*
+ * 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.solr.analytics.function.mapping;
+
+import org.apache.solr.SolrTestCaseJ4;
+import org.apache.solr.analytics.function.mapping.ExistsFunction;
+import org.apache.solr.analytics.value.AnalyticsValueStream;
+import org.apache.solr.analytics.value.BooleanValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestBooleanValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestDoubleValueStream;
+import org.junit.Test;
+
+public class ExistsFunctionTest extends SolrTestCaseJ4 {
+
+ @Test
+ public void singleValueParameterTest() {
+ TestBooleanValue val = new TestBooleanValue();
+
+ AnalyticsValueStream uncasted = ExistsFunction.creatorFunction.apply(new AnalyticsValueStream[] {val});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ val.setExists(false);
+ assertFalse(func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValue(true).setExists(true);
+ assertTrue(func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValue(false).setExists(true);
+ assertTrue(func.getBoolean());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void multiValueParameterTest() {
+ TestDoubleValueStream val = new TestDoubleValueStream();
+
+ AnalyticsValueStream uncasted = ExistsFunction.creatorFunction.apply(new AnalyticsValueStream[] {val});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ val.setValues(2, 30.0);
+ assertTrue(func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValues();
+ assertFalse(func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValues(21234.65);
+ assertTrue(func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValues();
+ assertFalse(func.getBoolean());
+ assertTrue(func.exists());
+ }
+}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a6d1681a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/FillMissingFunctionTest.java
----------------------------------------------------------------------
diff --git a/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/FillMissingFunctionTest.java b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/FillMissingFunctionTest.java
new file mode 100644
index 0000000..ea82193
--- /dev/null
+++ b/solr/contrib/analytics/src/test/org/apache/solr/analytics/function/mapping/FillMissingFunctionTest.java
@@ -0,0 +1,717 @@
+/*
+ * 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.solr.analytics.function.mapping;
+
+import java.time.Instant;
+import java.time.format.DateTimeParseException;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.Iterator;
+
+import org.apache.solr.SolrTestCaseJ4;
+import org.apache.solr.analytics.value.AnalyticsValue;
+import org.apache.solr.analytics.value.AnalyticsValueStream;
+import org.apache.solr.analytics.value.BooleanValue;
+import org.apache.solr.analytics.value.BooleanValueStream;
+import org.apache.solr.analytics.value.DateValue;
+import org.apache.solr.analytics.value.DateValueStream;
+import org.apache.solr.analytics.value.DoubleValue;
+import org.apache.solr.analytics.value.DoubleValueStream;
+import org.apache.solr.analytics.value.FloatValue;
+import org.apache.solr.analytics.value.FloatValueStream;
+import org.apache.solr.analytics.value.IntValue;
+import org.apache.solr.analytics.value.IntValueStream;
+import org.apache.solr.analytics.value.LongValue;
+import org.apache.solr.analytics.value.LongValueStream;
+import org.apache.solr.analytics.value.StringValue;
+import org.apache.solr.analytics.value.StringValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestAnalyticsValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestAnalyticsValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestBooleanValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestBooleanValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestDateValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestDateValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestDoubleValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestDoubleValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestFloatValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestFloatValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestIntValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestIntValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestLongValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestLongValueStream;
+import org.apache.solr.analytics.value.FillableTestValue.TestStringValue;
+import org.apache.solr.analytics.value.FillableTestValue.TestStringValueStream;
+import org.junit.Test;
+
+public class FillMissingFunctionTest extends SolrTestCaseJ4 {
+
+ @Test
+ public void castingTest() {
+ assertTrue(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestBooleanValue(), new TestStringValue()}) instanceof StringValue);
+
+ assertFalse(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestIntValue(), new TestFloatValue()}) instanceof IntValue);
+
+ assertFalse(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestBooleanValue(), new TestStringValueStream()}) instanceof AnalyticsValue);
+
+ assertFalse(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestLongValue(), new TestAnalyticsValue()}) instanceof LongValue);
+
+ assertTrue(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestIntValue(), new TestLongValue()}) instanceof DoubleValue);
+
+ assertFalse(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestDateValue(), new TestStringValue()}) instanceof DateValue);
+
+ assertFalse(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestBooleanValueStream(), new TestStringValue()}) instanceof AnalyticsValue);
+
+ assertTrue(FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {new TestDoubleValue(), new TestIntValueStream()}) instanceof DoubleValueStream);
+ }
+
+ @Test
+ public void singleValueBooleanTest() {
+ TestBooleanValue val = new TestBooleanValue();
+ TestBooleanValue filler = new TestBooleanValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof BooleanValue);
+ BooleanValue func = (BooleanValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getBoolean();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue(true).setExists(true);
+ filler.setValue(false).setExists(true);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValue(false).setExists(true);
+ filler.setValue(false).setExists(true);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValue(true).setExists(true);
+ filler.setExists(false);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setValue(false).setExists(true);
+ filler.setExists(false);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(false).setExists(true);
+ assertEquals(false, func.getBoolean());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(true).setExists(true);
+ assertEquals(true, func.getBoolean());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueIntTest() {
+ TestIntValue val = new TestIntValue();
+ TestIntValue filler = new TestIntValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof IntValue);
+ IntValue func = (IntValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getInt();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue(21).setExists(true);
+ filler.setValue(234).setExists(true);
+ assertEquals(21, func.getInt());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(-234).setExists(true);
+ assertEquals(-234, func.getInt());
+ assertTrue(func.exists());
+
+ val.setValue(52334).setExists(true);
+ filler.setExists(false);
+ assertEquals(52334, func.getInt());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueLongTest() {
+ TestLongValue val = new TestLongValue();
+ TestLongValue filler = new TestLongValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof LongValue);
+ LongValue func = (LongValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getLong();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue(21L).setExists(true);
+ filler.setValue(234L).setExists(true);
+ assertEquals(21L, func.getLong());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(234L).setExists(true);
+ assertEquals(234L, func.getLong());
+ assertTrue(func.exists());
+
+ val.setValue(-52334L).setExists(true);
+ filler.setExists(false);
+ assertEquals(-52334L, func.getLong());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueFloatTest() {
+ TestFloatValue val = new TestFloatValue();
+ TestFloatValue filler = new TestFloatValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof FloatValue);
+ FloatValue func = (FloatValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getFloat();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue(-21.324F).setExists(true);
+ filler.setValue(23423.423342F).setExists(true);
+ assertEquals(-21.324F, func.getFloat(), .00000001);
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(3124123.32F).setExists(true);
+ assertEquals(3124123.32F, func.getFloat(), .00000001);
+ assertTrue(func.exists());
+
+ val.setValue(2345.345543F).setExists(true);
+ filler.setExists(false);
+ assertEquals(2345.345543F, func.getFloat(), .00000001);
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueDoubleTest() {
+ TestDoubleValue val = new TestDoubleValue();
+ TestDoubleValue filler = new TestDoubleValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof DoubleValue);
+ DoubleValue func = (DoubleValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getDouble();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue(-21.324).setExists(true);
+ filler.setValue(23423.423342).setExists(true);
+ assertEquals(-21.324, func.getDouble(), .00000001);
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(3124123.32).setExists(true);
+ assertEquals(3124123.32, func.getDouble(), .00000001);
+ assertTrue(func.exists());
+
+ val.setValue(2345.345543).setExists(true);
+ filler.setExists(false);
+ assertEquals(2345.345543, func.getDouble(), .00000001);
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueDateTest() throws DateTimeParseException {
+ Date date1 = Date.from(Instant.parse("1810-12-02T10:30:15Z"));
+ Date date2 = Date.from(Instant.parse("1950-02-23T14:54:34Z"));
+ Date date3 = Date.from(Instant.parse("2023-11-01T20:30:15Z"));
+
+ TestDateValue val = new TestDateValue();
+ TestDateValue filler = new TestDateValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof DateValue);
+ DateValue func = (DateValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getLong();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue("1810-12-02T10:30:15Z").setExists(true);
+ filler.setValue("2023-11-01T20:30:15Z").setExists(true);
+ assertEquals(date1.getTime(), func.getLong());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue("1950-02-23T14:54:34Z").setExists(true);
+ assertEquals(date2.getTime(), func.getLong());
+ assertTrue(func.exists());
+
+ val.setValue("2023-11-01T20:30:15Z").setExists(true);
+ filler.setExists(false);
+ assertEquals(date3.getTime(), func.getLong());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueStringTest() {
+ TestStringValue val = new TestStringValue();
+ TestStringValue filler = new TestStringValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof StringValue);
+ StringValue func = (StringValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getString();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue("abc123").setExists(true);
+ filler.setValue("def456").setExists(true);
+ assertEquals("abc123", func.getString());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue("abc456").setExists(true);
+ assertEquals("abc456", func.getString());
+ assertTrue(func.exists());
+
+ val.setValue("def123").setExists(true);
+ filler.setExists(false);
+ assertEquals("def123", func.getString());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void singleValueObjectTest() {
+ TestAnalyticsValue val = new TestAnalyticsValue();
+ TestAnalyticsValue filler = new TestAnalyticsValue();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof AnalyticsValue);
+ AnalyticsValue func = (AnalyticsValue) uncasted;
+
+ // Value doesn't exist
+ val.setExists(false);
+ filler.setExists(false);
+ func.getObject();
+ assertFalse(func.exists());
+
+ // Value exists
+ val.setValue("abc123").setExists(true);
+ filler.setValue(new Date(123)).setExists(true);
+ assertEquals("abc123", func.getObject());
+ assertTrue(func.exists());
+
+ val.setExists(false);
+ filler.setValue(new Boolean(true)).setExists(true);
+ assertEquals(new Boolean(true), func.getObject());
+ assertTrue(func.exists());
+
+ val.setValue(new Long(234)).setExists(true);
+ filler.setExists(false);
+ assertEquals(new Long(234), func.getObject());
+ assertTrue(func.exists());
+ }
+
+ @Test
+ public void multiValueBooleanTest() {
+ TestBooleanValueStream val = new TestBooleanValueStream();
+ TestBooleanValueStream filler = new TestBooleanValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof BooleanValueStream);
+ BooleanValueStream func = (BooleanValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamBooleans( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues(true);
+ filler.setValues(true, false);
+ Iterator<Boolean> values1 = Arrays.asList(true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues(true, false);
+ Iterator<Boolean> values2 = Arrays.asList(true, false).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues(true, false, true);
+ filler.setValues();
+ Iterator<Boolean> values3 = Arrays.asList(true, false, true).iterator();
+ func.streamBooleans( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next(), value);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueIntTest() {
+ TestIntValueStream val = new TestIntValueStream();
+ TestIntValueStream filler = new TestIntValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof IntValueStream);
+ IntValueStream func = (IntValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamInts( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues(323, -9423);
+ filler.setValues(-1234, 5433, -73843, 1245144);
+ Iterator<Integer> values1 = Arrays.asList(323, -9423).iterator();
+ func.streamInts( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next().intValue(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues(312423, -12343, -23, 2);
+ Iterator<Integer> values2 = Arrays.asList(312423, -12343, -23, 2).iterator();
+ func.streamInts( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next().intValue(), value);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues(1423, -413543);
+ filler.setValues();
+ Iterator<Integer> values3 = Arrays.asList(1423, -413543).iterator();
+ func.streamInts( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next().intValue(), value);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueLongTest() {
+ TestLongValueStream val = new TestLongValueStream();
+ TestLongValueStream filler = new TestLongValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof LongValueStream);
+ LongValueStream func = (LongValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues(323L, -9423L);
+ filler.setValues(-1234L, -5433L, -73843L, 1245144L);
+ Iterator<Long> values1 = Arrays.asList(323L, -9423L).iterator();
+ func.streamLongs( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next().longValue(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues(-312423L, 12343L, 23L, 2L);
+ Iterator<Long> values2 = Arrays.asList(-312423L, 12343L, 23L, 2L).iterator();
+ func.streamLongs( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next().longValue(), value);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues(1423L, -413543L);
+ filler.setValues();
+ Iterator<Long> values3 = Arrays.asList(1423L, -413543L).iterator();
+ func.streamLongs( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next().longValue(), value);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueFloatTest() {
+ TestFloatValueStream val = new TestFloatValueStream();
+ TestFloatValueStream filler = new TestFloatValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof FloatValueStream);
+ FloatValueStream func = (FloatValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamFloats( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues(323.213F, -9423.5F);
+ filler.setValues(-1234.9478F, -5433.234F, -73843F, 1245144.2342F);
+ Iterator<Float> values1 = Arrays.asList(323.213F, -9423.5F).iterator();
+ func.streamFloats( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value, .00000001);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues(-312423.2F, 12343.234823F, 23.582F, 2.23F);
+ Iterator<Float> values2 = Arrays.asList(-312423.2F, 12343.234823F, 23.582F, 2.23F).iterator();
+ func.streamFloats( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value, .00000001);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues(1423.23039F, -413543F);
+ filler.setValues();
+ Iterator<Float> values3 = Arrays.asList(1423.23039F, -413543F).iterator();
+ func.streamFloats( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next(), value, .00000001);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueDoubleTest() {
+ TestDoubleValueStream val = new TestDoubleValueStream();
+ TestDoubleValueStream filler = new TestDoubleValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof DoubleValueStream);
+ DoubleValueStream func = (DoubleValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamDoubles( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues(323.213, -9423.5);
+ filler.setValues(-1234.9478, -5433.234, -73843.0, 1245144.2342);
+ Iterator<Double> values1 = Arrays.asList(323.213, -9423.5).iterator();
+ func.streamDoubles( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value, .00000001);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues(-312423.2, 12343.234823, 23.582, 2.23);
+ Iterator<Double> values2 = Arrays.asList(-312423.2, 12343.234823, 23.582, 2.23).iterator();
+ func.streamDoubles( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value, .00000001);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues(1423.23039, -413543.0);
+ filler.setValues();
+ Iterator<Double> values3 = Arrays.asList(1423.23039, -413543.0).iterator();
+ func.streamDoubles( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next(), value, .00000001);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueDateTest() throws DateTimeParseException {
+ Date date1 = Date.from(Instant.parse("1810-12-02T10:30:15Z"));
+ Date date2 = Date.from(Instant.parse("1931-03-16T18:15:45Z"));
+ Date date3 = Date.from(Instant.parse("2023-11-01T20:30:15Z"));
+
+ TestDateValueStream val = new TestDateValueStream();
+ TestDateValueStream filler = new TestDateValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof DateValueStream);
+ DateValueStream func = (DateValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamLongs( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues("1810-12-02T10:30:15Z");
+ filler.setValues("1931-03-16T18:15:45Z", "2023-11-01T20:30:15Z");
+ Iterator<Long> values1 = Arrays.asList(date1.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next().longValue(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues("1931-03-16T18:15:45Z", "1810-12-02T10:30:15Z");
+ Iterator<Long> values2 = Arrays.asList(date2.getTime(), date1.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next().longValue(), value);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues("2023-11-01T20:30:15Z", "1931-03-16T18:15:45Z");
+ filler.setValues();
+ Iterator<Long> values3 = Arrays.asList(date3.getTime(), date2.getTime()).iterator();
+ func.streamLongs( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next().longValue(), value);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueStringTest() {
+ TestStringValueStream val = new TestStringValueStream();
+ TestStringValueStream filler = new TestStringValueStream();
+
+ AnalyticsValueStream uncasted = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+ assertTrue(uncasted instanceof StringValueStream);
+ StringValueStream func = (StringValueStream) uncasted;
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamStrings( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues("abc");
+ filler.setValues("123", "def");
+ Iterator<String> values1 = Arrays.asList("abc").iterator();
+ func.streamStrings( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues("def", "12341");
+ Iterator<String> values2 = Arrays.asList("def", "12341").iterator();
+ func.streamStrings( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues("string1", "another string", "the final and last string");
+ filler.setValues();
+ Iterator<String> values3 = Arrays.asList("string1", "another string", "the final and last string").iterator();
+ func.streamStrings( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next(), value);
+ });
+ assertFalse(values3.hasNext());
+ }
+
+ @Test
+ public void multiValueObjectTest() {
+ TestAnalyticsValueStream val = new TestAnalyticsValueStream();
+ TestAnalyticsValueStream filler = new TestAnalyticsValueStream();
+
+ AnalyticsValueStream func = FillMissingFunction.creatorFunction.apply(new AnalyticsValueStream[] {val, filler});
+
+ // No values
+ val.setValues();
+ filler.setValues();
+ func.streamObjects( value -> {
+ assertTrue("There should be no values to stream", false);
+ });
+
+ // Values exist
+ val.setValues("asdfs");
+ filler.setValues(new Date(12312), new Long(213123L));
+ Iterator<Object> values1 = Arrays.<Object>asList("asdfs").iterator();
+ func.streamObjects( value -> {
+ assertTrue(values1.hasNext());
+ assertEquals(values1.next(), value);
+ });
+ assertFalse(values1.hasNext());
+
+ val.setValues();
+ filler.setValues(new Double(3234.42), "replacement");
+ Iterator<Object> values2 = Arrays.<Object>asList(new Double(3234.42), "replacement").iterator();
+ func.streamObjects( value -> {
+ assertTrue(values2.hasNext());
+ assertEquals(values2.next(), value);
+ });
+ assertFalse(values2.hasNext());
+
+ val.setValues(new Date(3), "3", new Float(3F));
+ filler.setValues();
+ Iterator<Object> values3 = Arrays.<Object>asList(new Date(3), "3", new Float(3F)).iterator();
+ func.streamObjects( value -> {
+ assertTrue(values3.hasNext());
+ assertEquals(values3.next(), value);
+ });
+ assertFalse(values3.hasNext());
+ }
+}