Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

package org.opensearch.sql.calcite.remote;

import static org.junit.Assume.assumeFalse;
import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_ARRAY;
import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_NESTED_SIMPLE;
import static org.opensearch.sql.util.MatcherUtils.rows;
Expand Down Expand Up @@ -295,6 +296,10 @@ public void testExpandWithEval() throws Exception {

@Test
public void testExpandEmptyArray() throws Exception {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 6;
Request insertRequest =
new Request(
Expand Down Expand Up @@ -324,6 +329,10 @@ public void testExpandEmptyArray() throws Exception {

@Test
public void testExpandOnNullField() throws Exception {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 6;
Request insertRequest =
new Request(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

package org.opensearch.sql.calcite.remote;

import static org.junit.Assume.assumeFalse;
import static org.opensearch.sql.legacy.TestsConstants.*;
import static org.opensearch.sql.util.MatcherUtils.*;

Expand Down Expand Up @@ -507,6 +508,10 @@ public void testStreamstatsCurrentAndWindowWithNull() throws IOException {

@Test
public void testStreamstatsGlobal() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 5;
Request insertRequest =
new Request(
Expand Down Expand Up @@ -666,6 +671,10 @@ public void testStreamstatsGlobalWithNullBucket() throws IOException {

@Test
public void testStreamstatsReset() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 5;
Request insertRequest =
new Request(
Expand Down Expand Up @@ -934,6 +943,10 @@ public void testMultipleStreamstatsWithNull1() throws IOException {

@Test
public void testMultipleStreamstatsWithNull2() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 5;
Request insertRequest =
new Request(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

package org.opensearch.sql.ppl;

import static org.junit.Assume.assumeFalse;
import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_BANK;
import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_DATE;
import static org.opensearch.sql.util.MatcherUtils.rows;
Expand Down Expand Up @@ -1565,6 +1566,10 @@ public void testExtract() throws IOException {

@Test
public void testCompareAgainstUTCDate() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
LocalDateTime now = LocalDateTime.now(ZoneOffset.UTC);
String isoTimestamp = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss'Z'"));
String pplTimestamp = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

package org.opensearch.sql.ppl;

import static org.junit.Assume.assumeFalse;
import static org.opensearch.sql.legacy.TestsConstants.*;
import static org.opensearch.sql.util.MatcherUtils.columnName;
import static org.opensearch.sql.util.MatcherUtils.rows;
Expand Down Expand Up @@ -1053,6 +1054,10 @@ public void testSearchWithNumericTimeRange() throws IOException {

@Test
public void testSearchTimeModifierWithSnappedWeek() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
// Test whether alignment to weekday works

final int docId = 101;
Expand Down Expand Up @@ -1141,6 +1146,10 @@ public void testSearchTimeModifierWithSnappedWeek() throws IOException {

@Test
public void testSearchWithRelativeTimeModifiers() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 101;

LocalDateTime currentTime = LocalDateTime.now(ZoneOffset.UTC);
Expand Down Expand Up @@ -1189,6 +1198,10 @@ public void testSearchWithRelativeTimeModifiers() throws IOException {

@Test
public void testSearchWithTimeUnitSnapping() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 101;

LocalDateTime currentHour = LocalDateTime.now(ZoneOffset.UTC).truncatedTo(ChronoUnit.HOURS);
Expand Down Expand Up @@ -1237,6 +1250,10 @@ public void testSearchWithTimeUnitSnapping() throws IOException {

@Test
public void testSearchWithQuarterlyModifiers() throws IOException {
assumeFalse(
"Test mutates docs via PUT+DELETE, which DataFormatAwareEngine"
+ " (analytics-engine storage path) does not support.",
isAnalyticsParquetIndicesEnabled());
final int docId = 101;

LocalDateTime currentQuarter =
Expand Down
Loading