@Override
    public SubscriptionType getSubscriptionType() {
        return subscriptionType;
    }
@Test
    public void testGetSubscriptionType() {
        SinkContext ctx = context;
        // make sure SinkContext can get SubscriptionType.
        Assert.assertEquals(ctx.getSubscriptionType(), SubscriptionType.Shared);
    }