<commit_before>##Ndb connection string to establish the connection with Ndb 
NDB_CONNECT_STRING=XXX:1186
NDB_DATABASE_NAME=XXX

##specifies the number of retries to attempt in the event of connection failure; 
##a negative value will result in the attempt to connect being repeated 
##indefinitely
NUMBER_OF_RETRIES_ATTEMPT=5
### specifies how often retries should be performed
RETRY_DELAY_IN_SECONDS=3
###Number of seconds to wait until first live node is detected
TIMEOUT_FOR_FIRST_ALIVE=30
### umber of seconds to wait after first live node is detected
TIMEOUT_AFTER_FIRST_ALIVE=30


TOTAL_NO_OF_COLUMN=17

TABLE_NAMES=yarn_containerid_toclean,yarn_nextheartbeat,yarn_rmnode_finishedapplications,yarn_containerstatus,yarn_secret_manager_keys

EVENT_COL_NAMES=pendingeventid,rmnodeid,containerid|pendingeventid,rmnodeid,nextheartbeat|pendingeventid,rmnodeid,applicationid|pendingeventid,rmnodeid,containerid,state,diagnostics,exitstatus,id,key

TOTAL_NUMBER_OF_CLASSES=5

JAVA_CLASS_NAME_1=AddContainersToClean|pendingeventid,setCidToCleanPendingId,(I)V|rmnodeid,setContainerIdToClenrmnodeid,(Ljava/lang/String;)V|containerid,setContainerId,(Ljava/lang/String;)V
JAVA_CLASS_NAME_2=X|pendingeventid,setNextHBPendingId,(I)V|rmnodeid,setNodeId,(Ljava/lang/String;)V|nextheartbeat,setNextHeartbeat,(Z)V
JAVA_CLASS_NAME_3=AddFinishedApplications|pendingeventid,setFinishedAppPendingId,(I)V|rmnodeid,setApplicationIdrmnodeid,(Ljava/lang/String;)V|applicationid,setApplicationId,(Ljava/lang/String;)V
JAVA_CLASS_NAME_4=AddHopContainerStatus|pendingeventid,setHopContainerStatusPendingId,(I)V|rmnodeid,setHopContainerStatusRMNodeId,(Ljava/lang/String;)V|containerid,setHopContainerStatusContainerid,(Ljava/lang/String;)V|state,setHopContainerStatusState,(Ljava/lang/String;)V|diagnostics,setHopContainerStatusDiagnostics,(Ljava/lang/String;)V|exitstatus,setHopContainerStatusExitstatus,(I)V
JAVA_CLASS_NAME_5=setKey|id,setKeyId,(Ljava/lang/String;)V|setKeyBytes,key,([B)

CALLBACK_CLASS_NAME=org/apache/hadoop/yarn/server/resourcemanager/NdbRtStreamingReceiver
SINGLE_THREAD_CALLBACK_METHOD=onEventMethod|()V
RESET_METHOD=resetObjects|()V
MULTI_THREAD_CLASS_BUILDER_NAME=buildStreamingRTComps|()Lorg/apache/hadoop/yarn/server/resourcemanager/StreamingRTComps;
MULTI_THREAD_CALLBACK_METHOD=onEventMethodMultiThread|(Lorg/apache/hadoop/yarn/server/resourcemanager/StreamingRTComps;)V


JAVA_CLASS_NAME_LISTS=buildContainersToClean,buildFinishedApplications,buildHopContainerStatus

## if it is X , then ordering won't happene at native level
REFERENCE_TABLE_NAME=X
## do we need to print throughput performance
PRINT_ENABLED=1
<commit_msg>correct streaming library configuration file<commit_after>##Ndb connection string to establish the connection with Ndb 
NDB_CONNECT_STRING=XXX:1186
NDB_DATABASE_NAME=XXX

##specifies the number of retries to attempt in the event of connection failure; 
##a negative value will result in the attempt to connect being repeated 
##indefinitely
NUMBER_OF_RETRIES_ATTEMPT=5
### specifies how often retries should be performed
RETRY_DELAY_IN_SECONDS=3
###Number of seconds to wait until first live node is detected
TIMEOUT_FOR_FIRST_ALIVE=30
### umber of seconds to wait after first live node is detected
TIMEOUT_AFTER_FIRST_ALIVE=30


TOTAL_NO_OF_COLUMN=20

TABLE_NAMES=yarn_containerid_toclean,yarn_nextheartbeat,yarn_rmnode_finishedapplications,yarn_containerstatus,yarn_secret_manager_keys,yarn_running_price

EVENT_COL_NAMES=pendingeventid,rmnodeid,containerid|pendingeventid,rmnodeid,nextheartbeat|pendingeventid,rmnodeid,applicationid|pendingeventid,rmnodeid,containerid,state,diagnostics,exitstatus|id,key|id,time,price

TOTAL_NUMBER_OF_CLASSES=6

JAVA_CLASS_NAME_1=AddContainersToClean|pendingeventid,setCidToCleanPendingId,(I)V|rmnodeid,setContainerIdToClenrmnodeid,(Ljava/lang/String;)V|containerid,setContainerId,(Ljava/lang/String;)V
JAVA_CLASS_NAME_2=X|pendingeventid,setNextHBPendingId,(I)V|rmnodeid,setNodeId,(Ljava/lang/String;)V|nextheartbeat,setNextHeartbeat,(Z)V
JAVA_CLASS_NAME_3=AddFinishedApplications|pendingeventid,setFinishedAppPendingId,(I)V|rmnodeid,setApplicationIdrmnodeid,(Ljava/lang/String;)V|applicationid,setApplicationId,(Ljava/lang/String;)V
JAVA_CLASS_NAME_4=AddHopContainerStatus|pendingeventid,setHopContainerStatusPendingId,(I)V|rmnodeid,setHopContainerStatusRMNodeId,(Ljava/lang/String;)V|containerid,setHopContainerStatusContainerid,(Ljava/lang/String;)V|state,setHopContainerStatusState,(Ljava/lang/String;)V|diagnostics,setHopContainerStatusDiagnostics,(Ljava/lang/String;)V|exitstatus,setHopContainerStatusExitstatus,(I)V
JAVA_CLASS_NAME_5=setKey|id,setKeyId,(Ljava/lang/String;)V|key,setKeyBytes,([B)V
JAVA_CLASS_NAME_6=X|time,setCurrentPriceTick,(J)V|price,setCurrentPrice,(F)V

CALLBACK_CLASS_NAME=org/apache/hadoop/yarn/server/resourcemanager/NdbRtStreamingReceiver
SINGLE_THREAD_CALLBACK_METHOD=onEventMethod|()V
RESET_METHOD=resetObjects|()V
MULTI_THREAD_CLASS_BUILDER_NAME=buildStreamingRTComps|()Lorg/apache/hadoop/yarn/server/resourcemanager/StreamingRTComps;
MULTI_THREAD_CALLBACK_METHOD=onEventMethodMultiThread|(Lorg/apache/hadoop/yarn/server/resourcemanager/StreamingRTComps;)V


JAVA_CLASS_NAME_LISTS=buildContainersToClean,buildFinishedApplications,buildHopContainerStatus

## if it is X , then ordering won't happene at native level
REFERENCE_TABLE_NAME=X
## do we need to print throughput performance
PRINT_ENABLED=1

{'fraction_non_alphanumeric': 0.08456698741672834, 'fraction_numerical': 0.007216876387860844, 'mean_word_length': 15.378787878787879, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '4633661', 'n_tokens_mistral': 1876, 'n_tokens_neox': 1826, 'n_words': 215}