[
https://issues.apache.org/jira/browse/PHOENIX-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan resolved PHOENIX-1462.
---------------------------------------------
Resolution: Fixed
Fix Version/s: 3.2
4.2
5.0.0
Pushed to master, 4.2 and 3.2. Thanks for the review.
> Create unit test for COUNT DISTINCT using compression
> -----------------------------------------------------
>
> Key: PHOENIX-1462
> URL: https://issues.apache.org/jira/browse/PHOENIX-1462
> Project: Phoenix
> Issue Type: Bug
> Reporter: James Taylor
> Assignee: ramkrishna.s.vasudevan
> Fix For: 5.0.0, 4.2, 3.2
>
> Attachments: Phoenix-1462.patch
>
>
> Create a unit test for PHOENIX-1455 and ensure that it is calling the code to
> do compression. Something like this:
> {code}
> @Category(NeedsOwnMiniClusterTest.class)
> public class CountDistinctCompressionIT extends
> BaseOwnClusterHBaseManagedTimeIT {
>
> @BeforeClass
> public static void doSetup() throws Exception {
> Map<String,String> props = Maps.newHashMapWithExpectedSize(3);
> // Must update config before starting server
> props.put(QueryServices.DISTINCT_VALUE_COMPRESS_THRESHOLD_ATTRIB,
> Long.toString(1));
> setUpTestDriver(new ReadOnlyProps(props.entrySet().iterator()));
> }
> @Test
> public void testDistinctCountOnColumn() throws Exception {
> String tenantId = getOrganizationId();
> initATableValues(tenantId, null, getDefaultSplits(tenantId), null);
> String query = "SELECT count(DISTINCT A_STRING) FROM aTable";
> Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
> Connection conn = DriverManager.getConnection(getUrl(), props);
> try {
> PreparedStatement statement = conn.prepareStatement(query);
> ResultSet rs = statement.executeQuery();
> assertTrue(rs.next());
> assertEquals(3, rs.getLong(1));
> assertFalse(rs.next());
> } finally {
> conn.close();
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
