@Test public void testGetMessageId() { long lid = 12345L; long eid = 34566L; long sequenceId = (lid << 28) | eid; MessageIdImpl id = (MessageIdImpl) FunctionCommon.getMessageId(sequenceId); assertEquals(lid, id.getLedgerId()); assertEquals(eid, id.getEntryId()); }
public static final MessageId getMessageId(long sequenceId) { long ledgerId = sequenceId >>> 28; long entryId = sequenceId & 0x0F_FF_FF_FFL; return new MessageIdImpl(ledgerId, entryId, -1); }
FunctionCommon { public static final MessageId getMessageId(long sequenceId) { long ledgerId = sequenceId >>> 28; long entryId = sequenceId & 0x0F_FF_FF_FFL; return new MessageIdImpl(ledgerId, entryId, -1); } }
FunctionCommon { public static final MessageId getMessageId(long sequenceId) { long ledgerId = sequenceId >>> 28; long entryId = sequenceId & 0x0F_FF_FF_FFL; return new MessageIdImpl(ledgerId, entryId, -1); }  }
FunctionCommon { public static final MessageId getMessageId(long sequenceId) { long ledgerId = sequenceId >>> 28; long entryId = sequenceId & 0x0F_FF_FF_FFL; return new MessageIdImpl(ledgerId, entryId, -1); }  static String printJson(MessageOrBuilder msg); static void mergeJson(String json, Builder builder); static int findAvailablePort(); static Class<?>[] getFunctionTypes(FunctionConfig functionConfig, ClassLoader classLoader); static Class<?>[] getFunctionTypes(Class userClass, boolean isWindowConfigPresent); static Object createInstance(String userClassName, ClassLoader classLoader); static Runtime convertRuntime(FunctionConfig.Runtime runtime); static FunctionConfig.Runtime convertRuntime(Runtime runtime); static org.apache.pulsar.functions.proto.Function.ProcessingGuarantees convertProcessingGuarantee(
            FunctionConfig.ProcessingGuarantees processingGuarantees); static FunctionConfig.ProcessingGuarantees convertProcessingGuarantee(
            org.apache.pulsar.functions.proto.Function.ProcessingGuarantees processingGuarantees); static Class<?> getSourceType(String className, ClassLoader classLoader); static Class<?> getSourceType(Class sourceClass); static Class<?> getSinkType(String className, ClassLoader classLoader); static void downloadFromHttpUrl(String destPkgUrl, File targetFile); static ClassLoader extractClassLoader(String destPkgUrl); static File createPkgTempFile(); static File extractFileFromPkgURL(String destPkgUrl); static NarClassLoader extractNarClassLoader(Path archivePath, File packageFile,
                                                       String narExtractionDirectory); static String getFullyQualifiedInstanceId(org.apache.pulsar.functions.proto.Function.Instance instance); static String getFullyQualifiedInstanceId(String tenant, String namespace,
                                                     String functionName, int instanceId); static final long getSequenceId(MessageId messageId); static final MessageId getMessageId(long sequenceId); static byte[] toByteArray(Object obj); static String getUniquePackageName(String packageName); static String getStateNamespace(String tenant, String namespace); static String getFullyQualifiedName(org.apache.pulsar.functions.proto.Function.FunctionDetails FunctionDetails); static String getFullyQualifiedName(String tenant, String namespace, String functionName); static String extractTenantFromFullyQualifiedName(String fqfn); static String extractNamespaceFromFullyQualifiedName(String fqfn); static String extractNameFromFullyQualifiedName(String fqfn); static Class<?> getTypeArg(String className, Class<?> funClass, ClassLoader classLoader); static double roundDecimal(double value, int places); }
FunctionCommon { public static final MessageId getMessageId(long sequenceId) { long ledgerId = sequenceId >>> 28; long entryId = sequenceId & 0x0F_FF_FF_FFL; return new MessageIdImpl(ledgerId, entryId, -1); }  static String printJson(MessageOrBuilder msg); static void mergeJson(String json, Builder builder); static int findAvailablePort(); static Class<?>[] getFunctionTypes(FunctionConfig functionConfig, ClassLoader classLoader); static Class<?>[] getFunctionTypes(Class userClass, boolean isWindowConfigPresent); static Object createInstance(String userClassName, ClassLoader classLoader); static Runtime convertRuntime(FunctionConfig.Runtime runtime); static FunctionConfig.Runtime convertRuntime(Runtime runtime); static org.apache.pulsar.functions.proto.Function.ProcessingGuarantees convertProcessingGuarantee(
            FunctionConfig.ProcessingGuarantees processingGuarantees); static FunctionConfig.ProcessingGuarantees convertProcessingGuarantee(
            org.apache.pulsar.functions.proto.Function.ProcessingGuarantees processingGuarantees); static Class<?> getSourceType(String className, ClassLoader classLoader); static Class<?> getSourceType(Class sourceClass); static Class<?> getSinkType(String className, ClassLoader classLoader); static void downloadFromHttpUrl(String destPkgUrl, File targetFile); static ClassLoader extractClassLoader(String destPkgUrl); static File createPkgTempFile(); static File extractFileFromPkgURL(String destPkgUrl); static NarClassLoader extractNarClassLoader(Path archivePath, File packageFile,
                                                       String narExtractionDirectory); static String getFullyQualifiedInstanceId(org.apache.pulsar.functions.proto.Function.Instance instance); static String getFullyQualifiedInstanceId(String tenant, String namespace,
                                                     String functionName, int instanceId); static final long getSequenceId(MessageId messageId); static final MessageId getMessageId(long sequenceId); static byte[] toByteArray(Object obj); static String getUniquePackageName(String packageName); static String getStateNamespace(String tenant, String namespace); static String getFullyQualifiedName(org.apache.pulsar.functions.proto.Function.FunctionDetails FunctionDetails); static String getFullyQualifiedName(String tenant, String namespace, String functionName); static String extractTenantFromFullyQualifiedName(String fqfn); static String extractNamespaceFromFullyQualifiedName(String fqfn); static String extractNameFromFullyQualifiedName(String fqfn); static Class<?> getTypeArg(String className, Class<?> funClass, ClassLoader classLoader); static double roundDecimal(double value, int places);  }