Skip to content

Commit

Permalink
Revert wrong test changes made in 1f7b151.
Browse files Browse the repository at this point in the history
Signed-off-by: Yury-Fridlyand <yury.fridlyand@improving.com>
  • Loading branch information
Yury-Fridlyand committed Jan 6, 2023
1 parent 90bae1f commit 735e9f7
Showing 1 changed file with 15 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -122,19 +122,19 @@ void getFieldTypes() {
fieldTypes,
allOf(
aMapWithSize(13),
hasEntry("name", OpenSearchDataType.of(ExprCoreType.STRING)),
hasEntry("address", OpenSearchDataType.of(Text)),
hasEntry("age", OpenSearchDataType.of(ExprCoreType.INTEGER)),
hasEntry("account_number", OpenSearchDataType.of(ExprCoreType.LONG)),
hasEntry("balance1", OpenSearchDataType.of(ExprCoreType.FLOAT)),
hasEntry("balance2", OpenSearchDataType.of(ExprCoreType.DOUBLE)),
hasEntry("gender", OpenSearchDataType.of(ExprCoreType.BOOLEAN)),
hasEntry("family", OpenSearchDataType.of(ExprCoreType.ARRAY)),
hasEntry("employer", OpenSearchDataType.of(ExprCoreType.STRUCT)),
hasEntry("birthday", OpenSearchDataType.of(ExprCoreType.TIMESTAMP)),
hasEntry("id1", OpenSearchDataType.of(ExprCoreType.BYTE)),
hasEntry("id2", OpenSearchDataType.of(ExprCoreType.SHORT)),
hasEntry("blob", OpenSearchDataType.of(Binary))
hasEntry("name", ExprCoreType.STRING),
hasEntry("address", (ExprType) OpenSearchDataType.of(Text)),
hasEntry("age", ExprCoreType.INTEGER),
hasEntry("account_number", ExprCoreType.LONG),
hasEntry("balance1", ExprCoreType.FLOAT),
hasEntry("balance2", ExprCoreType.DOUBLE),
hasEntry("gender", ExprCoreType.BOOLEAN),
hasEntry("family", ExprCoreType.ARRAY),
hasEntry("employer", ExprCoreType.STRUCT),
hasEntry("birthday", ExprCoreType.TIMESTAMP),
hasEntry("id1", ExprCoreType.BYTE),
hasEntry("id2", ExprCoreType.SHORT),
hasEntry("blob", (ExprType) OpenSearchDataType.of(Binary))
));
}

Expand All @@ -146,15 +146,15 @@ void checkCacheUsedForFieldMappings() {
OpenSearchIndex index = new OpenSearchIndex(client, settings, "test");
assertThat(index.getFieldTypes(), allOf(
aMapWithSize(1),
hasEntry("name", OpenSearchDataType.of(ExprCoreType.STRING))));
hasEntry("name", STRING)));

//Change mocked response, but `getFieldTypes` should return cached value
lenient().when(client.getIndexMappings("test")).thenReturn(
ImmutableMap.of("test", new IndexMapping(ImmutableMap.of("name", "text"))));

assertThat(index.getFieldTypes(), allOf(
aMapWithSize(1),
hasEntry("name", OpenSearchDataType.of(ExprCoreType.STRING))));
hasEntry("name", STRING)));
}

@Test
Expand Down

0 comments on commit 735e9f7

Please sign in to comment.