Parvin Etibarli Java

 1. Bubble sort. public static int bubble3 ( int [] arr) { boolean swapped; int count = 0 ; int n = arr. length ; for ( int i = 0 ; i < n - 1 ; i++) { swapped = false ; for ( int j = 0 ; j < n - i - 1 ; j++) { count++; if (arr[j] > arr[j + 1 ]) { swapped = true ; int temp = arr[j]; arr[j] = arr[j + 1 ]; arr[j + 1 ] = temp; } } if (!swapped) break ; } return count; } 2. Selection sort. public static int selectionSort1 ( int [] arr) { int count = 0 ; int n = arr. length ; for ( int i = 0 ; i < n - 1 ; i++) { int min = i; for ( int j = i + 1 ; j < n; j++) { count++; if (arr[j] < arr[min]) { min = j; } } if (min != i) { int temp = arr[i]; arr[i] = arr[min]; arr[min] = temp; } ...

package az.etibarli.queue; public class CircularQueue< T > { private T [] queue ; private int size = 0 ; private int front = 0 ; private int end = 0 ; public CircularQueue () { this ( 5 ); } public CircularQueue ( int capacity) { queue = ( T []) new Object[capacity]; } public boolean add ( T element) { if (isFull()) { resize(); } queue [ end ++] = element; end = end % queue . length ; size ++; return true ; } public T remove () { if (isEmpty()) { return null ; } T element = queue [ front ]; queue [ front ] = null ; front = ( front + 1 ) % queue . length ; size --; return element; } public T peek () { if (isEmpty()) { return null ; } return queue [ front ]; } public int size () { return size ; } public boolean isEmpty () { ...

 

Gradle dependencies: plugins { id 'java' id 'application' } group = 'az.etibarli' version = '1.0-SNAPSHOT' java { toolchain { languageVersion = JavaLanguageVersion. of ( 11 ) } } repositories { mavenCentral() } dependencies { implementation 'org.apache.flink:flink-java:1.17.1' implementation 'org.apache.flink:flink-streaming-java:1.17.1' implementation 'org.apache.flink:flink-clients:1.17.1' } application { mainClass = 'az.etibarli.WordCountStreaming' // Make sure this matches your main class } jar { manifest { attributes 'Main-Class' : 'az.etibarli.WordCountStreaming' } }  

package az.etibarli; import java.io.IOException; import java.nio.file.*; public class Main { public static void main (String[] args) throws IOException, InterruptedException { WatchService watchService = FileSystems. getDefault ().newWatchService(); Path path = Paths. get ( "/Users/etibarliparvin/Desktop/Test2" ); path.register(watchService, StandardWatchEventKinds. ENTRY_CREATE , StandardWatchEventKinds. ENTRY_DELETE , StandardWatchEventKinds. ENTRY_MODIFY ); System. out .println( "Watching directory: " + path); while ( true ) { // Infinite loop to keep watching WatchKey key = watchService.take(); // Blocking call, waits for an event for (WatchEvent<?> event : key.pollEvents()) { System. out .println( "Event type: " + event.kind() + " | File affected: " + event.context()); } boo...

  package az.kapitalbank.integration.asanfinance.logging; import com.fasterxml.jackson.core.JsonStreamContext; import net.logstash.logback.mask.ValueMasker; import org.apache.commons.lang3.StringUtils; import java.util.Objects; import java.util.regex.Matcher; import java.util.regex.Pattern; public class CustomLogFieldMasker implements ValueMasker { private Pattern messagePattern ; private Pattern panPattern ; public void setMessageProperty (String messageProperty) { this . messagePattern = buildPattern(messageProperty); } public void setPanProperty (String panProperty) { this . panPattern = buildPattern(panProperty); } private Pattern buildPattern (String pattern) { return StringUtils. isEmpty (pattern) ? null : Pattern. compile (pattern, Pattern. MULTILINE ); } @Override public Object mask (JsonStreamContext context, Object value) { if (Objects. isNull (value)) { return null ; } if ...